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

创建消息队列结果表

更新时间:2017-12-14 20:36:50

什么是消息队列(Message Queue)

消息队列(Message Queue,简称MQ)是阿里云商用的专业消息中间件,是企业级互联网架构的核心产品,基于高可用分布式集群技术,搭建了包括发布订阅、消息轨迹、资源统计、定时(延时)、监控报警等一套完整的消息云服务。MQ历史超过7年,帮您实现分布式计算场景中所有异步解耦功能,是阿里双11使用的核心产品。MQ由阿里巴巴集团中间件技术部自主研发,是原汁原味的阿里集团中间件技术精华之沉淀,是性价比最高、最可靠的企业级消息中间件产品。

流计算可以将消息队列作为流式数据输入,如下:

  1. CREATE TABLE stream_test_hotline_agent (
  2. id INTEGER,
  3. len BIGINT,
  4. content varchar
  5. ) WITH (
  6. type='mq',
  7. endpoint='XXXXX',
  8. accessID='XXXXX',
  9. accessKey='xxxxxx',
  10. topic='blink_daily_test_topic_1',
  11. producerGroup='PID_001',
  12. tag='asd',
  13. encoding='utf-8',
  14. fieldDelimiter=',',
  15. retryTimes='5',
  16. sleepTimeMs='500'
  17. );

WITH参数

参数 注释说明 备注
topic 写入的MetaQ队列名
endpoint 地址
accessID 填写自己的ID
accessKey 填写自己的Key
producerGroup 写入的群组
tag 写入的标签 可选,默认为空
fieldDelimiter 字段分割符 可选,默认为\u0001 表示 Crtl+A 和 \001,(暂不支持\001写法)
encoding 编码 可选,默认为utf-8
retryTimes 写入重试次数 可选,默认为10
sleepTimeMs 重试间隔时间 可选,默认为1000(毫秒)
本文导读目录