асинхронный цикл обработки событий эквивалентен uvloop - PullRequest
Новая
       33

асинхронный цикл обработки событий эквивалентен uvloop

0 голосов
/ 03 ноября 2018

У меня есть цикл событий с методом сопрограммы, использующим asyncio.

Я с энтузиазмом ищу эквивалент следующего примера, используя вместо него uvloop .

Вот простой asyncio пример цикла событий: 

import asyncio

async def read(**kwargs):
    oid = kwargs.get('oid', '0.0.0.0.0.0')
    time = kwargs.get('time', 1)
    try:
        print('start: ' + oid)
    except Exception as exc:
        print(exc)
    finally:
        await asyncio.sleep(time)
        print('terminate: ' + oid)


def event_loop(configs):
    loop = asyncio.get_event_loop()

    for conf in configs:
        asyncio.ensure_future(read(oid=conf['oid'], time=conf['time']))

    return loop

if __name__ == '__main__':
    snmp_configurations = [
        {'time': 5, 'oid': '1.3.6.3.2.4'},
        {'time': 6, 'oid': '1.3.6.3.5.8'},
    ]  # TODO :: DUMMY
    loop = event_loop(snmp_configurations)
    try:
        loop.run_forever()
    except KeyboardInterrupt:
        pass
    finally:
        print("Closing Loop")
        loop.close()

Вопрос:

  • Как изменить приведенный выше фрагмент кода с помощью uvloop ?

  • Правильно ли следующее изменение для использования uvloop с большей производительностью? 

    import uvloop

def event_loop(configs):
    asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())  # TODO  :: uvloop.
    loop = asyncio.get_event_loop()

 `   for conf in configs:
        asyncio.ensure_future(read(oid=conf['oid'], time=conf['time']))

    return loop

[ Примечание ]:

  • uvloop утверждает, что Asyncio ускоряется в 2-4 раза.

1 Ответ

0 голосов
/ 03 ноября 2018

Просто установите политику цикла событий перед вызовом asyncio.get_event_loop(). 

import asyncio
import uvloop
asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())

async def read(**kwargs):
    oid = kwargs.get('oid', '0.0.0.0.0.0')
    time = kwargs.get('time', 1)
    try:
        print('start: ' + oid)
    except Exception as exc:
        print(exc)
    finally:
        await asyncio.sleep(time)
        print('terminate: ' + oid)


def event_loop(configs):
    loop = asyncio.get_event_loop()

    for conf in configs:
        asyncio.ensure_future(read(oid=conf['oid'], time=conf['time']))

    return loop

if __name__ == '__main__':
    snmp_configurations = [
        {'time': 5, 'oid': '1.3.6.3.2.4'},
        {'time': 6, 'oid': '1.3.6.3.5.8'},
    ]  # TODO :: DUMMY
    loop = event_loop(snmp_configurations)
    try:
        loop.run_forever()
    except KeyboardInterrupt:
        pass
    finally:
        print("Closing Loop")
        loop.close()

Да, этот код правильный. Вы можете установить политику цикла событий после импорта. 

import uvloop
import asyncio
asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())  # TODO  :: uvloop.

def event_loop(configs):

    loop = asyncio.get_event_loop()

    for conf in configs:
        asyncio.ensure_future(read(oid=conf['oid'], time=conf['time']))

    return loop
...