PutAzureDataExplorer

PutAzureDataExplorer Processor

类型全限定名：cn.org.acal.lynxus.processors.azure.data.explorer.PutAzureDataExplorer

所属 Bundle：cn.org.acal.lynxus:lynxus-azure-nar:2.11.8

描述

充当 Azure 数据资源管理器接收器，将 FlowFiles 发送到提供的终结点。数据可以通过排队摄取或流式摄取发送到 Azure 数据资源管理器群集。

属性

下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。

名称	默认值	可选值	描述
Kusto Ingest Service		控制器服务 API： `KustoIngestService` cn.org.acal.lynxus-lynxus-azure-services-api-nar-2.11.8	Azure 数据资源管理器 Kusto 摄取服务
Database Name			用于引入数据的 Azure 数据资源管理器数据库名称支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Table Name			用于引入数据的 Azure 数据资源管理器表名称支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Ingest Mapping Name			负责将数据存储在适当列中的映射的名称。支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Data Format		avro — 支持逻辑类型和 snappy 压缩编解码器的 Avro 格式 apacheavro — 支持逻辑类型和 snappy 压缩编解码器的 Avro 格式。 csv — 以逗号分隔值（,）的文本文件。更多信息参见 RFC 4180：Common Format and MIME Type for Comma-Separated Values (CSV) Files。 json — 包含以 \n 或 \r\n 分隔的 JSON 对象的文本文件。更多信息参见 JSON Lines (JSONL)。 multijson — 包含属性容器（每个代表一条记录）的 JSON 数组，或以空格、\n 或 \r\n 分隔的任意数量属性容器的文本文件。每个属性容器可跨多行。除非数据不是属性容器，否则此格式比 JSON 更可取。 orc — 一个 ORC 文件。 parquet — 一个 parquet 文件。 psv — 以竖线（\|）分隔值的文本文件。 scsv — 以分号（;）分隔值的文本文件。 sohsv — 以 SOH 分隔值的文本文件。（SOH 是 ASCII 码位 1。此格式由 HDInsight 中的 Hive 使用）。 tsv — 以制表符分隔值（\t）的文本文件。 tsve — 以制表符分隔值（\t）的文本文件。使用反斜杠（\）作为转义字符。 txt — 一个文本文件，行之间用 \n 分隔。空行被跳过	发送到 Azure 数据资源管理器的数据的格式。支持的格式包括：avro、csv、json 支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Partially Succeeded Routing Strategy	`failure`	success failure	定义导致部分成功状态的 FlowFiles 的路由位置。
Streaming Enabled	`false`	true false	是否将数据流式传输到 Azure 数据资源管理器。
Ingestion Ignore First Record	`false`	true false	定义摄取时是否忽略第一条记录。
Poll for Ingest Status	`false`	true false	确定在 Azure 数据资源管理器的摄取完成后是否轮询摄取状态
Ingest Status Polling Timeout	`5 m`		定义轮询摄取状态的总时间
Ingest Status Polling Interval	`5 s`		定义轮询摄取状态的时间间隔值

关系 (Relationships)

名称	描述	自动终止
`failure`	摄取处理失败	否
`success`	摄取处理成功	否

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。

PutAzureDataExplorer Processor

描述

标签

属性

关系 (Relationships)

状态管理

受限 (Restricted)

输入要求