如何从网站连接/监听nsqd

2024-04-25 20:23:21 发布

您现在位置:Python中文网/ 问答频道 /正文

所以我有一个简单的flask服务器,想听听nsqd(我的nsqd和nsqlookupd dockers运行得很好。)我使用python中的gnsq作为实现这一点的工具

server.py:

from flask import Flask
import gnsq

consumer = gnsq.Consumer('test_topic', 'test_channel', '0.0.0.0:4161')

@consumer.on_message.connect
def handler(consumer, message):
    print ('got message:', message.body)

consumer.start()

app = Flask(__name__)

@app.route("/")
def hello():
    return "Flasky"

当我运行服务器时,我得到的只是

[0.0.0.0:4161] connection failed (NSQSocketError(57, 'Socket is not connected'))

我也尝试过更换端口,但仍然坚持


Tags: 工具testimport服务器appflaskmessageserver