建立消息隊列（MQ）結果表

本頁目錄

• 消息隊列MQ
• WITH參數

消息隊列（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. );

參數	注釋說明	備注
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（毫秒）

本文轉自實時計算——

建立消息隊列（MQ）結果表