nsq_tornado_asyncio_writer.py

import nsq
import time
import asyncio
import tornado
import tornado.ioloop
import tornado.platform.asyncio

def pub_callback(conn, data):
    print(data)

async def go():
    writer = nsq.Writer(('127.0.0.1:4150'))

    for i in range(10):
        await asyncio.sleep(.1)
        writer.pub('test', time.strftime('%H:%M:%S').encode(), pub_callback)

if __name__ == '__main__':
    tornado.platform.asyncio.AsyncIOMainLoop().install()
    loop = asyncio.get_event_loop()
    loop.run_until_complete(go())