数据湖探索 DLI-CloudTable OpenTSDB输出流:示例

时间:2023-11-01 16:20:09

示例

将流weather_out的数据输出到表格存储服务CloudTable的OpenTSDB中。

 1 2 3 4 5 6 7 8 910111213141516
CREATE SINK STREAM weather_out (  timestamp_value LONG, /* 时间 */  temperature FLOAT, /* 温度值 */  humidity FLOAT, /* 湿度值 */  location STRING /* 地点 */)  WITH (    type = "opentsdb",    region = "xxx",    cluster_id = "e05649d6-00e2-44b4-b0ff-7194adaeab3f",    tsdb_metrics = "weather",    tsdb_timestamps = "${timestamp_value}",    tsdb_values = "${temperature}; ${humidity}",    tsdb_tags = "location:${location},signify:temperature; location:${location},signify:humidity",    batch_insert_data_num = "10");
support.huaweicloud.com/sqlref-flink-dli/dli_08_0244.html