tornado - キューからメッセージをフェッチしてプッシュできる 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)

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