Вызов асинхронной функции из синхронной функции внутри Юпитера ⇐ Python

[Anonymous]

В нашем проекте ряд функций состоит из 2 вкуса: асинхронно и синхронно. Мы пишем асинхронную версию и предоставляем runa () обертку вокруг Asyncio.run () функция:

Код: Выделить всё

async def read_sensor_async():
print("Reading sensor...")
# Actual code
return 9 # Simulate sensor reading

def read_sensor():
return runa(read_sensor_async())

def runa(func):
# Prepare steps...
return asyncio.run(func)
< /code>
Кажется, что до этого момента все в порядке. Однако, когда мы запускаем read_sensor () 

в ноутбуке Юпитера (что означает внутри цикла событий). Мы получаем RuntimeError для вызова asyncio.run () . Читая документацию, это ожидаемое поведение. Таким образом, чтобы справиться с этой ситуацией, нам нужно подготовить Runa к работе как внутри, так и за пределами цикла событий. Вот наша версия 2: < /p>

Код: Выделить всё

def runa(func):
# Prepare steps...

with contextlib.suppress(RuntimeError):
return asyncio.run(func)

# Gets here means we are inside an event loop
return await func

Проблема с этой версией состоит в том, что Runa () является синхронной, мы не можем использовать await . Что мы можем сделать, чтобы вызвать func ?
обновление
Лучший вопрос: как мы можем переписать функцию read_sensor () , чтобы работать синхронно и асинхронно?>

Подробнее здесь: https://stackoverflow.com/questions/796 ... de-jupyter