12.2 数据接入任务
数据接入管理从外部数据源向 TDengine TSDB 的时序数据接入。可从管理后台 → 数据接入访问。
数据接入页面列出所有 TDengine 连接。点击某个连接可管理其接入任务、代理和数据采集代理配置。
12.2.1 数据接入任务
数据接入任务选项卡列出某个连接的所有已配置接入任务，包含以下列：ID、名称、类型、目标、创建时间、代理、指标和状态。
工具栏提供启动、停止、删除、导入和导出任务的控制按钮，以及刷新按钮和设置选项。
创建任务
点击 + 创建新任务。配置以下部分：
基本信息
| 字段 | 说明 |
|---|---|
| 名称（必填） | 任务的描述性名称 |
| 类型 | 数据源协议（参见下方任务类型列表） |
| 目标（必填） | 目标 TDengine 数据库。点击**+ 创建数据库**新建一个。 |
连接配置
配置字段因任务类型而异。以下是两个常见示例。
示例：OPC-UA
OPC-UA（OPC 统一架构）是一种广泛用于连接 PLC、传感器和 SCADA 系统的工业协议。
连接配置
| 字段 | 说明 |
|---|---|
| 服务器端点（必填） | OPC-UA 服务器地址，如 127.0.0.1:6666/OPCUA/ServerPath |
| 故障转移服务器端点 | 用于高可用性的备用服务器端点 |
| 安全模式 | OPC-UA 安全模式（无、签名、签名并加密） |
| 安全策略 | 使用的加密策略 |
| 安全通道证书 | 安全通道的证书文件 |
| 证书私钥 | 证书的私钥文件 |
| 连接超时 | 连接超时时间（秒，默认：10） |
| 请求超时 | 请求超时时间（秒，默认：10） |
认证
选择匿名、用户名（用户名和密码）或证书（客户端证书文件）。
点击检查连接验证后再继续。
数据集
| 字段 | 说明 |
|---|---|
| 根节点 ID | 数据点发现的起始节点，如 ns=1;i=1001 |
| 命名空间 | 要包含的 OPC-UA 命名空间（连接检查后填充） |
| 节点类 | 要采集的 OPC-UA 节点类型（默认：全部） |
| 节点 ID 正则表达式 | 按节点 ID 模式过滤数据点 |
| 节点名称正则表达式 | 按名称模式过滤数据点 |
| 超级表名称（必填） | 目标超级表名称模板（默认：opc_{type}） |
| 值列名称 | 值的列名（默认：val） |
| 时间戳 | 时间戳来源（默认：original_ts） |
采集
| 字段 | 说明 |
|---|---|
| 采集模式 | subscribe（推送）或 poll（拉取） |
| 节点更新模式 | 节点元数据更新的处理方式 |
| 节点更新间隔 | 检查节点变更的间隔（秒，默认：600） |
示例：SparkplugB（MQTT）
SparkplugB 是一种基于 MQTT 的协议，广泛用于工业物联网部署。
连接配置
| 字段 | 说明 |
|---|---|
| Broker 地址（必填） | MQTT Broker 地址，如 mqtt://host:1883 |
| MQTT 协议版本 | 使用的 MQTT 版本 |
| 客户端 ID | MQTT 客户端标识符 |
| 心跳间隔 | 心跳间隔（秒） |
| 用户名 | MQTT 用户名 |
| 密码 | MQTT 密码 |
| TLS 验证 | 为 MQTT 连接启用 TLS |
| 组 ID | 要订阅的 Sparkplug 组 ID |
| 节点设备列表 | 要采集的 Sparkplug 节点/设备 ID 列表 |
| 消息类型 | 要处理的 Sparkplug 消息类型 |
所有任务类型都有高级选项部分，可进行进一步调优。
点击提交创建任务。
备注
数据接入功能由 TDengine TSDB 的数据接入引擎驱动。有关所有任务类型及其配置字段的完整文档，请参阅 TDengine TSDB 文档。
支持的任务类型
IDMP 支持从以下数据源类型接入数据：
| 类型 | 说明 |
|---|---|
| TDengine 数据订阅 | 订阅 TDengine TMQ 主题，实现实时数据接入 |
| TDengine 查询 | 通过 SQL 查询按计划从 TDengine 拉取数据 |
| PI | OSIsoft PI 系统 |
| PI 回填 | 从 OSIsoft PI 历史回填数据 |
| OPC-UA | OPC 统一架构 |
| OPC-DA | OPC 数据访问 |
| InfluxDB | InfluxDB 时序数据库 |
| OpenTSDB | OpenTSDB 时序数据库 |
| PostgreSQL | PostgreSQL 关系型数据库 |
| Oracle | Oracle 数据库 |
| Microsoft SQL Server | Microsoft SQL Server |
| MongoDB | MongoDB 文档数据库 |
| SparkplugB | MQTT Sparkplug B 协议 |
| KingHistorian | KingHistorian 工业历史数据库 |
| Pulsar | Apache Pulsar 消息队列 |
| Pulsar-Tuya | 集成涂鸦物联网平台的 Pulsar |
12.2.2 代理
代理选项卡列出为此连接注册的 IDMP 代理进程，包含以下列：ID、名称、创建时间和状态。代理负责处理需要中间进程的协议任务。
12.2.3 数据采集代理
数据采集代理选项卡提供第三方代理的配置指南，这些代理可使用标准协议直接向 TDengine 写入数据：
| 代理 | 说明 |
|---|---|
| Prometheus | 配置 Prometheus 远程写入，将指标推送到 TDengine |
| Telegraf | 配置 Telegraf 输出插件，将指标写入 TDengine |
| InfluxDB 行协议 | 使用 InfluxDB 行协议线格式写入数据 |
| OpenTSDB JSON 协议 | 使用 OpenTSDB HTTP JSON API 写入数据 |
| OpenTSDB Telnet 协议 | 使用 OpenTSDB telnet 接口写入数据 |
点击任意卡片查看该代理的配置指南。
