SMN输出流

概述

CS将作业的输出数据输出到消息通知服务（SMN）中。

消息通知服务（Simple Message Notification，简称SMN）为CS提供可靠的、可扩展的、海量的消息处理服务，它大大简化系统耦合，能够根据用户的需求，向订阅终端主动推送消息。可用于连接云服务、向多个协议推送消息以及集成在产生或使用通知的任何其他应用程序等场景。SMN的更多信息，请参见《消息通知服务用户指南》。

语法

语法格式

CREATE SINK STREAM stream_id xxx WITH(type = "smn",region = "",topic_urn = "",urn_column = "",message_subject = "",message_column = "")

语法说明

注意事项

无。

示例

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

//静态主题配置
CREATE SINK STREAM over_speed_warning (
  over_speed_message STRING /* over speed message */
)
WITH (
  type = "smn",
  region = "cn-north-1" ,
  topic_Urn = "urn:smn:cn-north-1:38834633fd6f4bae813031b5985dbdea:ddd",
  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 = "cn-north-1" ,
urn_column = "over_speed_urn",  
message_subject = "message title",  
message_column = "over_speed_message"
);