处理器:服务数据收集器
服务数据收集器处理器从指定的服务收集数据。例如,“bgp”服务将是 BGP 会话的状态。要监视的对象通过图形查询和密钥进行配置。在 BGP 示例中,密钥的计算结果应为 locallp、localAs、remoteIP 或远程 As。对于基于接口的服务(如“接口”和“lldp”),key 是接口名称。
参数 | 说明 |
---|---|
输入类型 | 无输入。这是一个源处理器。 |
输出类型 | 表(数字或离散状态) |
图形查询 (graph_query) | 图形上的一个或多个查询指定为字符串,或此类查询的列表。(字符串将在将来的版本中弃用。多个查询应提供表达式字段引用的所有命名节点(包括additional_properties)。图形查询在“操作”图形上执行。可以使用具有相应索引的“query_result”变量访问查询结果。例如,如果查询名称为“ps”的属性集节点,则结果将显示为“query_result[0][”ps“]”。 在收集器处理器 ( 在其他处理器中,它用于常规参数化,并且仅支持作为查询列表。 graph_query: "node("system", role="leaf", name="system"). out("hosted_interfaces"). node("interface", name="iface").out("link"). node("link", role="spine_leaf")" graph_query: ["node("system", role="leaf", name="system")", "node("system", role="spine", name="system")"] |
服务名称 (service_name) | 自定义收集器服务的名称。 |
钥匙 | 属性名称列表,其值将用作服务的关键参数。从图形查询到服务所需的任何键的表达式映射。对于 lldp,它是一个带有接口名称的字符串。对于 bgp,它是一个类似 (src_addr、src_asn、dst_addr、dst_asn、vrf_name、addr_family)的元组,其中addr_family应该是 ipv4、ipv6 或 evpn 之一。对于接口,它是一个带有接口名称的字符串。 |
查询扩展 | 对于最初由图形查询返回的每个路径,传递给每个生成器,后者生成一组项目,对于每个项目,它生成一个由相应属性名称扩展的新路径,该值是所生成项的值集。 |
查询分组依据 (query_group_by) | 图形查询中使用的节点和关系名称的(字符串)列表,用于对查询结果进行分组。此列表中的每个元素表示字段中的一个命名节点或关系匹配器 当分组处于活动状态( 不为 null) 以下列表描述了此字段的各种值的行为:
|
查询标记筛选器 (query_tag_filter) | 按分配的标记筛选图形查询中的命名节点。 |
系统 ID | 从图形查询到system_id的表达式映射,例如,如果“system”是图形查询中的名称,则为 “system.system_id”。 |
其他密钥 | 每个额外的键/值对都用于扩展输出阶段的属性,其中值被视为在图形查询上下文中执行的表达式,其结果用作具有相应键的属性值。将为每个项目评估此属性的值,以便将项目与相应收集器服务提供的衡量指标相关联。关联由键完成,因为每个收集器报告一组指标,其中每个指标由键标识,格式特定于每个收集器。 |
启用流式处理 (enable_streaming) | 使输出级的示例流式传输(如果启用)。默认为 False 的可选布尔值。如果设置为 True,则此处理器的所有输出级都将在通用 protobuf 架构中进行流式传输。 |
示例:服务数据收集器
ode("system", name="system").out("hosted_interfaces"). node("interface", name="iface").out("link"). node("link", role="spine_leaf")" system_id: "system.system_id" key: "interface.if_name" role: "system.role"
在此示例中,我们创建一个 DSS,其中包含系统中每个交换矩阵接口的条目。每个条目都由“system_id”和“key”隐式标记(其中key恰好是接口服务的接口名称)。此外,由于我们指定了一个额外的属性“角色”,因此每个条目也按系统角色标记。
[system_id=spine1,role=spine,key=eth0]: "up" [system_id=spine2,role=spine,key=eth1]: "down" [system_id=leaf0,role=leaf, key=swp1]: "up"