下載連接器（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版控制臺，創建、更新和刪除全托管自定義連接器。

• 數據集成流程：使用連接器集成物聯網平臺時序數據的完整流程。