Доходность сопрограмм продолжать основной

Question

Я пытаюсь использовать сопрограмму для отправки данных в NATS (система обмена сообщениями nats.io).

Когда я пытаюсь вызвать этот код без аргументов и для цикла, он работает отлично.

Но когда я добавляю аргументы, функция yield nc.connect ничего не возвращает и переходит к основной функции.

Как я могу назвать любую сопрограмму с аргументами?

@tornado.gen.coroutine
def process_events_list(events):  
    try: 
        nc = NATS()
        parser = SafeConfigParser()
        conf = os.path.realpath(
        os.path.join(os.getcwd(),'ev_nats\\ev_nats.ini'))
        parser.read(conf)
        endpoints = ast.literal_eval(parser.get('Nats', 'Servers'))
        subject = parser.get('Nats', 'Subject')
        opts = {"servers": endpoints}
        **yield nc.connect(**opts)**  # wont connect return to main        
        for ev in events:
            yield nc.publish(subject, ev)
        yield nc.flush()
        log("Published")
    except Exception, e:
        log(e)

if __name__=='__main__': # if run directly, not called by event_dispatcher.py
   evt = ['1','2','3']
   tornado.ioloop.IOLoop.instance().run_sync(lambda : process_events_list(evt))

Answer 1

Я попытался бы отладить далее, действителен ли список конечных точек, которые вы передаете на сервер. В противном случае, что-то подобное должно сработать, если вы можете подключиться к серверу.

# coding: utf-8
import tornado.ioloop
import tornado.gen
from nats.io.client import Client as NATS

@tornado.gen.coroutine
def main(events):
    print("Args:", events)
    nc = NATS()

    # Establish connection to the server.
    options = { "servers": ["nats://127.0.0.1:4222"] }
    yield nc.connect(**options)

    for e in events:
        yield nc.publish("example", "event:{}".format(e))

if __name__ == '__main__':
    events = ['1', '2', '8']
    tornado.ioloop.IOLoop.instance().run_sync(lambda: main(events))