キューからメッセージを取り出してプッシュできるnsqライターを実装する方法は？

Question

私はスレッドでioloopを実行し、メッセージをnsqdに書き込むだけです。試してみてください：

#!/usr/bin/env python2 
# coding=utf-8 

import tornado 
import time 
from nsq.writer import Writer 

w = Writer(["bj1:4150", "bj2:4150"], reconnect_interval=15) 
w.connect() 


@tornado.gen.coroutine 
def future_pub(topic, msg): 
    result = w.pub(topic, msg) 
    print(result) 
    time.sleep(3) 
    raise tornado.gen.Return(result) 


@tornado.gen.coroutine 
def main(): 
    while True: 
     try: 
      future = future_pub("test", "message") 
      yield future 
     except Exception as e: 
      print(e.message) 


tornado.ioloop.IOLoop.instance().run_sync(main) 

しかし、それは動作しませんでした。私たちを手伝ってくれますか？ありがとうございました！

Answer 1

を実行したことがないので、接続は開かず、Writerはメッセージを公開できません。
PeriodicCallbackを使用して1秒に1回メッセージを送信するための例：https://pynsq.readthedocs.org/en/latest/writer.htmlを参照してください。