文档首页 > > SQL语法参考> 流作业SQL语法> 创建输出流> SMN输出流

SMN输出流

分享
更新时间:2020/08/03 GMT+08:00

功能描述

DLI将Flink作业的输出数据输出到消息通知服务(SMN)中。

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

语法格式

1
2
3
4
5
6
7
8
9
CREATE SINK STREAM stream_id xxx 
  WITH(
    type = "smn",
    region = "",
    topic_urn = "",
    urn_column = "",
    message_subject = "",
    message_column = ""
  )

关键字

表1 关键字说明

参数

是否必选

说明

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中。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
//静态主题配置
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"
  );
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
//动态主题配置
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"
  );
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问