python - 避免 pynsq 中的消息超时

Question

例如，我通过发出以下命令向 NSQ 发送消息：

curl -d "test2" http://127.0.0.1:4151/pub?topic=hello

我发现如果消息处理程序执行时间超过 100 秒，它将抛出并且该消息将超时。

ERROR:nsq.client:[127.0.0.1:4150:hello:channel]      
ERROR: ConnectionClosedError('Stream is closed',)
WARNING:nsq.reader:[127.0.0.1:4150:hello:channel] connection closed

我能做些什么来避免这种超时？

这是我的代码：

def process_message(message):
    print(message)
    time.sleep(100)
    message.touch()
    return True

r_check = nsq.Reader(
     message_handler=process_message,
    nsqd_tcp_addresses=['127.0.0.1:4150'],
    topic='hello', channel='channel',
    lookupd_poll_interval=15,
    lookupd_connect_timeout=100000,
    lookupd_request_timeout=100000,
    max_tries=10
)

nsq.run()

谢谢。

Answer 1

您应该message.touch()在处理消息之前调用，以便告诉 NSQD 您需要更多时间来处理消息。

NSQD 中有两个参数控制消息超时：max-msg-timeout 和 msg-timeout。

Matt Reiferson 解释了他们是如何在这里工作的。