使用python向nats服务器发送消息

问题描述

nats 的组和主题是：

subject:
svc.croupier.croupier
queue:
croupier 

如何在python中向nats服务器发送消息？

尝试过：

import asyncio
from nats.aio.client import Client as NATS
from stan.aio.client import Client as STAN
import json

data = json.dumps({"symbol": "GOOG","price": 1200 }).encode()

nc = NATS()


await nc.connect("127.0.0.1:4222")
response = await nc.request("svc.croupier.croupier",data,timeout=10)
print("Received response: {message}".format(
            message=response.data.decode()))
print(response)

向此队列和主题发送消息，特别是 json 的正确方法是什么？

问候

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）