全部产品
阿里云办公

创建消息队列(MQ)结果表

更新时间:2018-09-29 14:47:14

消息队列MQ

消息队列(Message Queue)简称MQ,是阿里云商用的专业消息中间件,是企业级互联网架构的核心产品。消息列队是基于高可用分布式集群技术,搭建了包括发布订阅、消息轨迹、资源统计、定时(延时)、监控报警等一套完整的消息云服务。
实时计算 Flink可以将消息队列作为流式数据输入,如下所示。

  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 地址 公共云内网接入(阿里云经典网络/VPC):华东1、华东2、华北1、华北2、华南1
香港的区域endpoint的地址是:onsaddr-internal.aliyun.com:8080
公共云公网接入地址是:http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet
accessID 填写自己的ID 无 
accessKey 填写自己的Key
producerGroup 写入的群组
tag 写入的标签 可选,默认为空
fieldDelimiter 字段分割符 可选,默认为\u0001 。表示 Crtl+A 和 \001,(暂不支持\001写法)。
encoding 编码 可选,默认为utf-8
retryTimes 写入重试次数 可选,默认为10
sleepTimeMs 重试间隔时间 可选,默认为1000(毫秒)