cs
SMN输出流
更新时间：2020/09/29 GMT+08:00
概述
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 = "")
语法说明
参数 |
是否必选 |
说明 |
|---|---|---|
type |
是 |
输出通道类型，smn表示输出到消息通知服务中。 |
region |
是 |
SMN所在区域。 |
topic_urn |
否 |
SMN服务的主题URN，用于静态主题URN配置。作为消息通知的目标主题，需要提前在SMN服务中创建。 与urn_column配置两者至少存在一个，同时配置时，topic_urn优先级更高。 |
urn_column |
否 |
包含主题URN内容的字段名，用于动态主题URN配置。 与topic_urn配置两者至少存在一个，同时配置时，topic_urn优先级更高。 |
message_subject |
是 |
发往SMN服务的消息标题，用户自定义。 |
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"
);
父主题： 创建输出流
