failed to mpub (192.168.1.199:4150, ['123']), data is SendError: no open connections (None)

[ghost]

No description provided.

[outman]

Without ioloop context

def publish(t: str, m: bytes):

    def producer(topic, message, callback=None):
        if not writer.conns:
            return writer.io_loop.add_callback(
                partial(producer, *(topic, message, callback))
            )
        writer.pub(topic, message, callback)

    def on_finish(conn, status_code):
        logger.info('publish_result:{},{}'.format(conn, status_code))
        io_loop.stop()

    writer = nsq.Writer(os.getenv('NSQ_NSQD_TCP_ADDRESS', '').split(','))
    io_loop = tornado.ioloop.IOLoop.instance()
    writer.io_loop.add_callback(
        partial(producer, *(t, m, on_finish))
    )
    io_loop.start()

With ioloop consumer context

def publish(t: str, m: bytes):

    def producer(topic, message, callback=None):
        if not writer.conns:
            return writer.io_loop.add_callback(
                partial(producer, *(topic, message, callback))
            )
        writer.pub(topic, message, callback)

    def on_finish(conn, status_code):
        logger.info('publish_result:{},{}'.format(conn, status_code))
        # io_loop.stop()

    writer = nsq.Writer(os.getenv('NSQ_NSQD_TCP_ADDRESS', '').split(','))
    # io_loop = tornado.ioloop.IOLoop.instance()
    writer.io_loop.add_callback(
        partial(producer, *(t, m, on_finish))
    )
    # io_loop.start()

[outman]

@aviezab
I'm very sorry, the code involved in that issue is too old and can no longer be found. If the message has been published successfully, you can check through the nsq management interface to see if the message is normal.