根据文档https://console.ng.bluemix.net/docs/services/MessageHub/index.html#messagehub应该可以通过 REST 向 MessageHub 提交消息并通过 MQLight 客户端接收它。但是,文档缺少示例并且有些……不透明。
所以,如果我创建 MQLight 主题,并让 python 客户端监听,
import json
import logging
import mqlight
import time
amqps = 'amqps://xxxxxxxxxxxxx.messagehub.services.us-south.bluemix.net:5671'
options = {
'user' : 'xxxxxxxxxxxxxxxx',
'password' : 'xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx'
}
def on_message(message_type, data, delivery):
d = json.loads(data)
print str(d)
def on_started(err):
client.subscribe('test', on_message = on_message)
def on_stopped(err):
logging.info('stopped')
client = mqlight.Client(amqps, security_options = options, client_id = 'client', on_started=on_started)
while True:
logging.info(str(client.get_state()))
time.sleep(5)
我将如何通过 curl 发布消息。我试过了,值字符串是base64编码的,
curl -i \
-X POST \
-H "X-Auth-Token:${APIKEY}" \
-H "Content-Type: application/vnd.kafka.binary.v1+json" \
--data '{"records":[{"value":"S2Fma2E="}]}' \
"https://kafka-rest-prod01.messagehub.services.us-south.bluemix.net:443/topics/MQLight/test"
但那又回来了,
{"error_code":404,"message":"HTTP 404 Not Found"}