SiteToSiteStatusReportingTask Reporting Task
描述
使用站点到站点协议发布状态事件。组件类型和名称过滤正则表达式
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| 目标 URL | | 目标 Lynxus 实例的 URL，如果是集群，则为 http(s)://host:port/lynxus 格式的逗号分隔地址列表。此目标 URL 仅用于发起站点到站点连接。此报告任务发送的数据将在目标的所有节点上进行负载均衡（如果是集群）。 支持表达式语言：是（仅使用环境/系统变量求值） | |
| 输入端口名称 | | 要将数据传送到的输入端口的名称。 支持表达式语言：是（仅使用环境/系统变量求值） | |
| SSL 上下文服务 | | 控制器服务 API：SSLContextProvidercn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 与目标通信时使用的 SSL 上下文服务。如果未指定，通信将不安全。 |
| 实例 URL | http://${hostname(true)}:8080/lynxus | 要在每个事件的内容 URI 中使用的此实例的 URL。 支持表达式语言：是（仅使用环境/系统变量求值） | |
| 压缩事件 | true |
| 指示是否压缩正在发送的数据。 |
| 通信超时 | 30 secs | 指定在确定发生错误并取消事务之前等待来自目标的响应的时间 | |
| 批大小 | 1000 | 指定单个批次中最多发送多少条记录。 | |
| 传输协议 | RAW |
| 指定用于站点到站点通信的传输协议。 |
| Proxy Configuration Service | | 控制器服务 API：ProxyConfigurationServicecn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 指定代理配置 Controller Service 来代理网络请求。 |
| 记录写入器 | | 控制器服务 API：RecordSetWriterFactorycn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 指定用于写出记录的Controller Service。 |
| 包含空值 | false |
| 指示记录中是否应包含空值。默认为 false |
| 平台 | lynxus | 用于每个状态记录中的平台字段的值。 支持表达式语言：是（仅使用环境/系统变量求值） | |
| 组件类型过滤正则表达式 | (Processor|ProcessGroup|RemoteProcessGroup|RootProcessGroup|Connection|InputPort|OutputPort) | 指定要报告哪些组件类型的正则表达式。匹配此正则表达式的任何组件类型都将包含在内。组件类型包括：Processor、RootProcessGroup、ProcessGroup、RemoteProcessGroup、Connection、InputPort、OutputPort 支持表达式语言：是（仅使用环境/系统变量求值） | |
| 组件名称过滤正则表达式 | .* | 指定要报告哪些组件名称的正则表达式。匹配此正则表达式的任何组件名称都将包含在内。 支持表达式语言：是（仅使用环境/系统变量求值） |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
详细说明
SiteToSiteStatusReportingTask
Site-to-Site Status Reporting Task 允许用户使用 Site To Site 协议发布 Status 事件。组件类型和名称的过滤正则表达式构成一个交集：只有同时匹配两个正则的组件才会被上报。不过， 无论流程组本身是否匹配组件过滤器，所有流程组都会被递归搜索以查找匹配的组件。
Record writer
用户可以定义 Record Writer，直接指定输出格式和数据，前提是输入 schema 如下：
{
"type": "record",
"name": "status",
"namespace": "status",
"fields": [
{
"name": "statusId",
"type": "string"
},
{
"name": "timestampMillis",
"type": {
"type": "long",
"logicalType": "timestamp-millis"
}
},
{
"name": "timestamp",
"type": "string"
},
{
"name": "actorHostname",
"type": "string"
},
{
"name": "componentType",
"type": "string"
},
{
"name": "componentName",
"type": "string"
},
{
"name": "parentId",
"type": [
"string",
"null"
]
},
{
"name": "parentName",
"type": [
"string",
"null"
]
},
{
"name": "parentPath",
"type": [
"string",
"null"
]
},
{
"name": "platform",
"type": "string"
},
{
"name": "application",
"type": "string"
},
{
"name": "componentId",
"type": "string"
},
{
"name": "activeThreadCount",
"type": [
"long",
"null"
]
},
{
"name": "flowFilesReceived",
"type": [
"long",
"null"
]
},
{
"name": "flowFilesSent",
"type": [
"long",
"null"
]
},
{
"name": "bytesReceived",
"type": [
"long",
"null"
]
},
{
"name": "bytesSent",
"type": [
"long",
"null"
]
},
{
"name": "queuedCount",
"type": [
"long",
"null"
]
},
{
"name": "bytesRead",
"type": [
"long",
"null"
]
},
{
"name": "bytesWritten",
"type": [
"long",
"null"
]
},
{
"name": "terminatedThreadCount",
"type": [
"long",
"null"
]
},
{
"name": "runStatus",
"type": [
"string",
"null"
]
},
{
"name": "bytesTransferred",
"type": [
"long",
"null"
]
},
{
"name": "flowFilesTransferred",
"type": [
"long",
"null"
]
},
{
"name": "inputContentSize",
"type": [
"long",
"null"
]
},
{
"name": "outputContentSize",
"type": [
"long",
"null"
]
},
{
"name": "queuedContentSize",
"type": [
"long",
"null"
]
},
{
"name": "versionedFlowState",
"type": [
"string",
"null"
]
},
{
"name": "activeRemotePortCount",
"type": [
"long",
"null"
]
},
{
"name": "inactiveRemotePortCount",
"type": [
"long",
"null"
]
},
{
"name": "receivedContentSize",
"type": [
"long",
"null"
]
},
{
"name": "receivedCount",
"type": [
"long",
"null"
]
},
{
"name": "sentContentSize",
"type": [
"long",
"null"
]
},
{
"name": "sentCount",
"type": [
"long",
"null"
]
},
{
"name": "averageLineageDuration",
"type": [
"long",
"null"
]
},
{
"name": "transmissionStatus",
"type": [
"string",
"null"
]
},
{
"name": "targetURI",
"type": [
"string",
"null"
]
},
{
"name": "inputBytes",
"type": [
"long",
"null"
]
},
{
"name": "inputCount",
"type": [
"long",
"null"
]
},
{
"name": "outputBytes",
"type": [
"long",
"null"
]
},
{
"name": "outputCount",
"type": [
"long",
"null"
]
},
{
"name": "transmitting",
"type": [
"boolean",
"null"
]
},
{
"name": "sourceId",
"type": [
"string",
"null"
]
},
{
"name": "sourceName",
"type": [
"string",
"null"
]
},
{
"name": "destinationId",
"type": [
"string",
"null"
]
},
{
"name": "destinationName",
"type": [
"string",
"null"
]
},
{
"name": "maxQueuedBytes",
"type": [
"long",
"null"
]
},
{
"name": "maxQueuedCount",
"type": [
"long",
"null"
]
},
{
"name": "queuedBytes",
"type": [
"long",
"null"
]
},
{
"name": "backPressureBytesThreshold",
"type": [
"long",
"null"
]
},
{
"name": "backPressureObjectThreshold",
"type": [
"long",
"null"
]
},
{
"name": "backPressureDataSizeThreshold",
"type": [
"string",
"null"
]
},
{
"name": "isBackPressureEnabled",
"type": [
"string",
"null"
]
},
{
"name": "processorType",
"type": [
"string",
"null"
]
},
{
"name": "averageLineageDurationMS",
"type": [
"long",
"null"
]
},
{
"name": "flowFilesRemoved",
"type": [
"long",
"null"
]
},
{
"name": "invocations",
"type": [
"long",
"null"
]
},
{
"name": "processingNanos",
"type": [
"long",
"null"
]
},
{
"name": "executionNode",
"type": [
"string",
"null"
]
},
{
"name": "counters",
"type": [
"null",
{
"type": "map",
"values": "string"
}
]
}
]
}