📣 极限科技诚招搜索运维工程师(Elasticsearch/Easysearch)- 全职/北京 👉 : 立即申请加入

适用版本: 6.8-8.9

1. 错误异常的基本描述 #

could not parse [weekly] schedule. invalid weekly times 是 Elasticsearch Watcher 在解析 weekly 类型 schedule(周调度)时抛出的异常。此错误表示 Watcher 已经确认这是 weekly 调度,但在解析周维度的触发时间定义时失败了。

常见现象 #

  • 创建或更新 watch 时返回 HTTP 400 错误。
  • 报错信息明确指出是 weekly schedule 的 times 无效。
  • 常见于手动编写 weekly schedule 配置时,或在使用模板生成配置时。
  • 如果星期值非法(如 INVALID)或时间格式错误(如 25:00),就会触发此错误。

典型报错与异常栈 #

{
  "error": {
    "root_cause": [
      {
        "type": "parse_exception",
        "reason": "could not parse [weekly] schedule. invalid weekly times"
      }
    ],
    "type": "parse_exception",
    "reason": "could not parse [weekly] schedule. invalid weekly times"
  },
  "status": 400
}

服务端日志中可能出现类似以下内容:

[2024-01-15T10:30:00,123][WARN ][o.e.x.w.t.s.WeeklySchedule] [node-1] failed to parse weekly schedule
ElasticsearchParseException[could not parse [weekly] schedule. invalid weekly times]
    at org.elasticsearch.xpack.watcher.trigger.schedule.WeeklySchedule.parse(WeeklySchedule.java:89)
    at org.elasticsearch.xpack.watcher.trigger.schedule.Schedule.parse(Schedule.java:123)
Caused by: ElasticsearchParseException[could not parse weekly times. expected an object; but found [VALUE_STRING]]

2. 为什么会发生这个错误 #

Watcher 的 WeeklySchedule.parse 方法会把对象或数组中的每项交给 WeekTimes.parse 处理。只要某个周时间对象中包含非法星期、错误时间格式或结构异常,就会被包装成这个错误。

常见原因包括:

  • 非法星期值:星期值必须是 MONTUEWEDTHUFRISATSUN 之一,其他值(如 Mondaymonday1INVALID)都是非法的。
  • 时间格式错误time 字段必须是 HH:MM 格式(24小时制),如 25:00ab:cd 都是非法的。
  • 结构异常WeekTimes.parse 期望对象是 {"on": ["MON"], "at": ["12:00"]} 格式,如果结构不对就会失败。
  • 数组元素非法:如果 weekly 是数组,其中某个元素解析失败就会导致整个解析失败。
  • 字段放错位置:把 monthlyyearly 的字段误放进 weekly 对象里。
  • 模板渲染问题:使用 Mustache 或 script 模板时,渲染结果可能格式不正确。

3. 如何排查和解决这个异常和解决这个异常 #

排查步骤 #

  1. 检查 trigger.schedule.weekly 的结构:确认是对象还是数组。

  2. 检查每个对象里的星期和时间字段是否合理

# 获取 watch 配置
GET _watcher/watch/<watch_id>?pretty

# 检查 trigger 部分的 weekly schedule
  1. 验证星期值和时间格式
# 正确的 weekly schedule 格式示例
PUT _watcher/watch/<watch_id>
{
  "trigger": {
    "schedule": {
      "weekly": {
        "on": ["MON", "FRI"],
        "at": ["12:00", "18:00"]
      }
    }
  },
  ...
}

合法的星期值:

  • MON - 星期一
  • TUE - 星期二
  • WED - 星期三
  • THU - 星期四
  • FRI - 星期五
  • SAT - 星期六
  • SUN - 星期日

时间格式:HH:MM(24小时制,如 00:0012:3023:59

  1. 如果使用数组,逐个排除元素来定位问题项
# weekly 也可以是数组
PUT _watcher/watch/<watch_id>
{
  "trigger": {
    "schedule": {
      "weekly": [
        {"on": ["MON"], "at": ["12:00"]},
        {"on": ["FRI"], "at": ["18:00"]}
      ]
    }
  }
}

排查时需要注意的问题 #

  • 注意星期值必须是大写的三字母缩写(MONTUE 等),不能是全称或其他格式。
  • 时间格式必须是 HH:MM,且小时在 0-23 范围内,分钟在 0-59 范围内。
  • 如果使用模板变量,确保变量渲染后是合法的值。

4. 如何解决这个错误 #

常用修复方式 #

  1. 修正非法星期值或时间值
# 修复前(错误:星期值非法)
PUT _watcher/watch/<watch_id>
{
  "trigger": {
    "schedule": {
      "weekly": {
        "on": ["Monday"],  # 错误:应该是 MON
        "at": ["12:00"]
      }
    }
  }
}

# 修复后(正确:使用合法的星期值)
PUT _watcher/watch/<watch_id>
{
  "trigger": {
    "schedule": {
      "weekly": {
        "on": ["MON", "FRI"],
        "at": ["12:00", "18:00"]
      }
    }
  }
}
  1. 清理 weekly 对象里不属于当前类型的字段
# 错误:包含了 monthly 的字段
"weekly": {
  "on": ["MON"],
  "at": ["12:00"],
  "day": 1  # 错误:这是 monthly 的字段
}

# 正确:只包含 weekly 支持的字段
"weekly": {
  "on": ["MON"],
  "at": ["12:00"]
}
  1. 给生成 weekly 配置的代码增加字段白名单校验

后续注意事项与推荐建议 #

  • 在编写 weekly schedule 配置时,严格参照官方文档中的示例。
  • 对动态生成的配置进行格式验证,确保星期值和时间格式合法。
  • 在测试环境验证 schedule 配置,特别是在使用模板或程序生成配置时。

借助 INFINI 产品提升排障效率 #

  • INFINI Console 提供可视化的 Watch 编辑和验证功能,可以在保存前检查 weekly schedule 配置的合法性,自动检测非法的星期值和时间格式。
  • INFINI Gateway 可以记录 Watcher API 的完整请求内容,帮助捕获 schedule 配置的详细错误上下文,并通过流量回放验证修复方案。
  • 通过 INFINI Console 的 Watch 测试功能,可以在不执行完整 Watch 的情况下验证 schedule 配置的合法性。

5. 小结 #

could not parse [weekly] schedule. invalid weekly times 是一个周时间定义错误,表示 weekly schedule 内部的某一项周时间定义无法被 WeekTimes.parse 接受。解决此问题的关键是:确保星期值是合法的三字母缩写(MONTUE 等),时间格式是 HH:MM,且字段结构正确。

通过 INFINI Console 的配置验证功能和 INFINI Gateway 的请求捕获能力,可以更高效地定位和修复 weekly schedule 的配置问题。

相关错误 #

参考文档 #

附:日志上下文 #

下面保留当前页面中的源码或日志片段,便于继续结合异常调用栈定位问题:

public WeeklySchedule parse(XContentParser parser) throws IOException {
    if (parser.currentToken() == XContentParser.Token.START_OBJECT) {
        try {
            return new WeeklySchedule(WeekTimes.parse(parser, parser.currentToken()));
        } catch (ElasticsearchParseException pe) {
            throw new ElasticsearchParseException("could not parse [{}] schedule. invalid weekly times", pe, TYPE);
        }
    }
    if (parser.currentToken() == XContentParser.Token.START_ARRAY) {
        List<WeekTimes> times = new ArrayList<>();
        XContentParser.Token token;