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

时间：2023-11-10 09:20:50

数据湖探索 DLI

示例

将流over_speed_warning的数据输出到消息通知服务SMN中。

//静态主题配置
CREATE SINK STREAM over_speed_warning (
  over_speed_message STRING /* over speed message */
)
  WITH (
    type = "smn",
    region = "xxx",
    topic_Urn = "xxx",
    message_subject = "message title",
    message_column = "over_speed_message"
  );

//动态主题配置
CREATE SINK STREAM over_speed_warning2 (  
    over_speed_message STRING, /* over speed message */  
    over_speed_urn STRING
)
  WITH (  
    type = "smn",  
    region = "xxx",
    urn_column = "over_speed_urn",  
    message_subject = "message title",  
    message_column = "over_speed_message"
  );