文档首页/ 数据湖探索 DLI/ Flink SQL语法参考/ 历史版本/ Flink SQL语法参考（不再演进，推荐使用Flink OpenSource SQL）/ 创建输出流/ SMN输出流
更新时间：2024-09-27 GMT+08:00
查看PDF
分享

SMN输出流

功能描述

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

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

SMN的更多信息，请参见《消息通知服务用户指南》。

语法格式

1
2
3
4
5
6
7
8
9
 
CREATE SINK STREAM stream_id (attr_name attr_type (',' attr_name attr_type)* ) 
  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 = "xxx",
    topic_Urn = "xxx",
    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 = "xxx",
    urn_column = "over_speed_urn",  
    message_subject = "message title",  
    message_column = "over_speed_message"
  );
父主题： 创建输出流