全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
流计算

创建消息服务结果表(MessageService)

更新时间:2017-12-29 15:20:00

阿里云消息服务(Message Service)是一种高效、可靠、安全、便捷、可弹性扩展的分布式消息服务。MNS能够帮助应用开发者在他们应用的分布式组件上自由的传递数据、通知消息,构建松耦合系统。流计算通常使用消息服务作为数据下游投递的目的端,用于告警等业务场景。需要注意的是,当前流计算对于消息服务的支持仅是作为数据输出,还不支持数据输入

DDL定义

示例代码如下:

  1. CREATE RESULT TABLE oneQueue (
  2. id BIGINT,
  3. name STRING
  4. ) WITH (
  5. type='mns',
  6. endpoint='http://xxxxx.mns.cn-hangzhou-internal.aliyuncs.com',
  7. roleArn='acs:ram::xxxxxx:role/aliyunstreamdefaultrole',
  8. queueName='oneQueue'
  9. );

注意:

  • 该SQL声明为oneQueue的MNS队列,流计算写出的方式按照将上述{字段名: 字段值}的json格式进行写入Message Service。

    例如,如果数据为1,hello2,aliyun,那么写出到MessageService服务的数据格式为:

    1. {'id': 1, 'name': 'hello'}
    2. {'id': 2, 'name': 'aliyun'}

WITH参数

字段名称 说明
type 数据存储类型,Message Service类型请填写’mns’ (全小写)
accessId 能够读写该queue的accessId
accessKey 能够读写该queue的accessKey
arnRole STS的role信息,如果使用的是STS方式连接需要指定该选项,该选项和accessId/accessKey选项之间必选其一
endpoint Message Service的Endpoint,例如http://xxxxx.mns.cn-hangzhou-internal.aliyuncs.com
topicName MessageService的Topic名称, 和queueName两者必选其一
queueName MessageService的Topic名称,和topicName两者必选其一

类型映射

MessageService本身是非结构化存储,实际上不存在类型。流计算按照业务上JSON格式输出要求,指定流计算内置几个类型即可。

本文导读目录