实时数据集成的连接器

下载连接器（IoT Connector）

连接器文件：iot-flink-connector-source.jar。

支持的数据类型

支持的存储表

• 产品属性时序表和产品事件表支持的数据字段如下：

  字段名称	数据类型	说明
  product_key	String	产品的ProductKey。
  device_name	String	设备名称。
  topic	String	上报数据的物模型Topic。
  body	String	上报的物模型属性或事件的具体信息。例如，上报物模型属性数据：{"test": 100}。

• 自定义存储表（时序表）支持的数据字段如下：

  字段名称	数据类型	说明
  real_table_name	String	自定义存储表（时序表）的表显示名。
  custom_body	String	存储表中存储的字段信息。例如，温度字段数据：{"temperature": 36}。

语法结构

• 产品属性时序表和产品事件表SQL配置示例：

  CREATE TABLE IoT_table(
    product_key STRING,
    device_name STRING,
    topic STRING
  ) WITH (
    'connector'='iot-source',
    'regionId'='<yourRegionId>',
    'accessId'='<yourAccessId>',
    'accessKey'='<yourAccessKey>',
    'tableName'='<yourTableName>',
    'iotInstanceId'='<yourIotInstanceId>',
    'clientId'='<yourClientId>',
    'uid' = '<aliyunUid>'
  );

• 自定义存储表（时序表）SQL配置示例：

  CREATE TABLE IoT_table(
    real_table_name STRING,
    custom_body STRING
  ) WITH (
    'connector'='iot-source',
    'regionId'='<yourRegionId>',
    'accessId'='<yourAccessId>',
    'accessKey'='<yourAccessKey>',
    'tableName'='<yourTableName>',
    'iotInstanceId'='<yourIotInstanceId>',
    'clientId'='<yourClientId>',
    'uid' = '<aliyunUid>'
  );

WITH参数

相关文档

• 管理自定义连接器：在实时计算Flink版控制台，创建、更新和删除全托管自定义连接器。

• 数据集成流程：使用连接器集成物联网平台时序数据的完整流程。