Marathon 布局约束

了解 Marathon 布局约束

Marathon 放置约束能够控制服务的运行位置,以便优化容错性(通过在多个节点上分散任务)或本地化(通过在同一节点上运行所有服务任务)。约束有三个部分:字段名称、算子和可选参数。该字段名称可以是代理节点的主机名或代理节点的任何属性。

字段名称

代理属性作为字段名称

字段名称以 @ 开头的约束引用代理属性。

主机名

字段名称与代理节点主机名相匹配时输入 @hostname 参见以下 UNIQUE operator,查看使用示例。

分域和分区作为字段名称

使用 @region@zone 字段名称配置 故障域感知和容量扩展.

属性作为字段名称

如果 @hostname@region@zone 未被指定为字段名称,那么字段名称将被解释为 Mesos 代理节点属性。Mesos 代理节点属性允许您标记代理节点。参见 mesos-slave --help,了解如何设置属性。如果代理节点上未定义指定的属性,大多数算子将拒绝在其上运行任务。事实上,只有 UNLIKE 算子将始终接受此邀约,但其他算子将始终拒绝。

Marathon 支持文本、标量、范围和数集属性值。为确定标量、范围和数集,Marathon 将对格式值执行字符串比较。格式与 Mesos 属性格式匹配。范围和数集的格式分别为 [begin-end,...]{item,...} 例如,您可能有一个格式为 [100-200] 的范围和格式为 {a,b,c}. 的数集。Regex 适用于 LIKE 和 UNLIKE 算子;如需匹配 ANY 值,请使用字符串 .*.

算子

CLUSTER 算子

(可选): 字符串值。 指定值后,就会采用值完全匹配的属性在代理节点上启动任务。

CLUSTER 支持您在共享某个属性的代理节点上运行服务的所有任务。这一属性在您的服务有特殊硬件,或者想在同一机架上运行这些服务以降低延迟时,以及其他情况下都非常实用。

命名字段名称 hostname 告诉 Marathon 应用程序或 Pod 启动的任务应在同一代理上启动:

  • 指定 hostname 的值后,就会在主机名与值匹配的代理上启动任务。 hostname 值为空或未指定时,第一个实例在 任意 代理节点上启动,其余任务也和该实例一起在同一代理上启动。

当字段名称为属性时,Marathon 处理任务的方式会不同:

  • 指定值后,任何代理只要带有一个根据字段命名的属性,且属性具有匹配该限制的值,均可启动任务。
  • 当值为空或未指定时,第一个实例会在具有根据字段命名的属性的任何代理上启动;该代理上属性的值用于匹配将来的限制。

示例

以下示例指定了运行应用程序任务的确切机架:

  1. {
  2. "id": "sleep-cluster",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["rack_id", "CLUSTER", "rack-1"]]
  6. }

此示例将值字段留空。这会告诉 Marathon ,所有应用程序任务都应在同一机架上运行,但不指定具体机架。

  1. {
  2. "id": "sleep-cluster",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["rack_id", "CLUSTER"]]
  6. }

此示例使用指定的 hostname,这意味着服务必须在特定节点上运行。

  1. {
  2. "id": "sleep-cluster",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["hostname", "CLUSTER", "a.specific.node.com"]]
  6. }

下面,字段已命名 hostname,但值为空。这会告诉 Marathon,所有应用程序任务必须在同一节点上运行,但不指定具体节点。

  1. {
  2. "id": "sleep-cluster",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["hostname", "CLUSTER"]]
  6. }

LIKE 算子

(必填):属性值的正则表达式。

LIKE 接受正则表达式作为参数,并且只允许在字段值与正则表达式匹配的代理节点上运行任务。请注意,必须匹配整个值(假设正则表达式周围有隐式 ^$

  1. {
  2. "id": "sleep-group-by",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["rack_id", "LIKE", "rack-[1-3]"]]
  6. }

如果相关属性是一个标量,则会利用半偶(half-even)舍入法舍入到最接近的千分位数;小数点后的零会去掉。

UNLIKE 算子

(必填):属性值的正则表达式。

UNLIKE 类似于 LIKE 算子,但指示 Marathon 仅在字段值 不与正则表达式匹配的代理节点上运行任务。请注意,必须匹配整个值(假设正则表达式周围有隐式 ^$

  1. {
  2. "id": "sleep-group-by",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["rack_id", "UNLIKE", "rack-[7-9]"]]
  6. }

MAX_PER 算子

(必填):是一个整数,例如 "2".

MAX_PER 接受数字作为指定每个组最大大小的参数。它可用于限制跨机架或数据中心的任务。

  1. {
  2. "id": "sleep-group-by",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["rack_id", "MAX_PER", "2"]]
  6. }

UNIQUE 算子

UNIQUE 不接受值。

UNIQUE 告诉 Marathon 在所有服务任务中执行唯一的属性。例如,以下限制确保每个主机上只有一个服务任务。

  1. {
  2. "id": "sleep-unique",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["hostname", "UNIQUE"]]
  6. }

GROUP_BY 算子

(可选): 是一个整数,例如 "3".

GROUP_BY 可用于在机架或数据中心之间均匀地分布任务,以实现高可用性。

  1. {
  2. "id": "sleep-group-by",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["rack_id", "GROUP_BY"]]
  6. }

Marathon 通过分析 Mesos 传入的邀约,仅知道属性的不同值(例如,“rack_id 如果任务尚未分散到所有可能的值,请指定限制中的值的数量。如果没有指定值的数量,就可能发现任务仅分配给一个值,即使您正在使用 GROUP_BY 限制。例如,在 3 个机架上分散时,使用:

  1. {
  2. "id": "sleep-group-by",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["rack_id", "GROUP_BY", "3"]]
  6. }

IS 算子

(必填):Mesos 标量或文本值,由 Mesos 属性和资源类型规范指定:

  1. scalar : floatValue
  2. floatValue : ( intValue ( "." intValue )? ) | ...
  3. intValue : [0-9]+
  4. text : [a-zA-Z0-9_/.-]

比较文本值

指定 IS 限制后,任务仅在具有指定值的节点上启动。

  1. {
  2. "id": "sleep-cluster",
  3. "cmd": "sleep 60",
  4. "instances": 3,
  5. "constraints": [["rack", "IS", "rack-1"]]
  6. }

比较标量值

比较标量时,将值与最接近的千分位数进行比较(使用半偶舍入法)。

假设节点的属性为“级别:0.8”,则匹配以下限制:

  1. [["level", "IS", "0.8"]]
  2. [["level", "IS", "0.80"]]
  3. [["level", "IS", "0.8001"]]