Не существует простого способа сделать это — обычно асинхронные функции можно вызывать только из асинхронных функций: именно так они и должны работать.

Причина в том, что любая промежуточная синхронная функция в вызове цепочек не должна быть «приостановлена», когда внутренняя функция выполняет оператор await и ожидает, что цикл выполнит другие параллельные задачи: для синхронной функции не существует никаких механизмов. приостановить и возобновить — вот что делает async def.

Итак, очевидный и правильный подход состоит в том, чтобы все ваши вызовы, связанные с функцией, которая должна будет ожидать операции ввода-вывода (или ее эквивалента), должны состоять из асинхронных вызовов.

Иногда это может привести к дублированию кода — существуют очень похожие функции, которые должны вызываться из синхронного кода, а другие — из асинхронного кода, и даже большие базы кода и расширенные платформы с трудом справляются с этим.

ОДНАКО, если вашей внутренней функции не понадобится результат вызова самой асинхронной функции, т. е. она может просто создать задачу с асинхронной функцией и вернуть эту задачу - асинхронная функция, вызывающая синхронную функцию, должна затем сохранить возвращенную задачу. и ждём этого:

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

Итак, для кода, которому просто не нужно возвращаемое значение:

import asyncio

async def work_for_data():
    time.sleep(3)
    return 42

# sync function, calling async function
def get_number():
    task = asyncio.create_task(work_for_data())
    return task

async def get_data():
    # trigger sync function that will start the tasks for producing async data
    number_task = get_number()
    # do more concurrent stuff
    
    ...
    # await for the data produced by `get_number()`:
    number = await number_task

async def run()
    global queue

    task = asyncio.create_task(get_data())
    await task


if __name__ == "__main__":
    asyncio.run(run())

Другие подходы заключаются в том, чтобы использовать синхронный код для создания задачи для промежуточной функции, которая будет ожидать целевую асинхронную функцию, и помещать ее возвращаемое значение в очередь, которое затем можно будет использовать в другом месте — всякий раз, когда результат будет готов. Или, если у синхронной функции будет сам код, который должен обрабатывать значения, созданные в асинхронном коде, то способ сделать это — установить обратный вызов, вызвав метод .add_done_callback для созданной задачи. Однако результат обработки этого обратного вызова не будет возвращен асинхронной функции, вызывающей функцию синхронизации (get_number). Если это необходимо, то предпочтительнее просто сделать всю цепочку вызовов асинхронной.

Нет проблем с планированием асинхронной функции из функции синхронизации, но в asyncio (и с одним потоком) невозможно, чтобы функция синхронизации ждала результата. Если управление не возвращается планировщику, никакая другая функция не может быть запущена и результат не будет вычислен. Каждая функция (синхронная или асинхронная), выполняемая в цикле событий asyncio, принадлежит задаче, и одновременно может выполняться только одна задача.

Вы должны использовать несколько потоков, и один из них будет запускать цикл событий. Другой поток(и) может отправлять работу и ждать результата. Вот как: https://docs.python.org/3/library/asyncio-dev.html#concurrency-and-multithreading

Не рекомендуется вызывать асинхронную функцию из функции синхронизации, поскольку она включает обмен данными между потоками и блокирует всю программу. Хороший способ решить эту проблему — адаптировать функции синхронизации к асинхронным частям и сделать асинхронной всю программу.

Однако есть обходной путь, который может «решить» вашу проблему.

1. Оберните асинхронную часть в asyncio.loop
2. Обработка передачи данных между синхронизирующей и асинхронной частью.

import asyncio

async def calc_async():
    # Use asyncio.sleep to non-blockingly wait for 2 seconds
    await asyncio.sleep(2)
    return 10

def sync_function():
    # Set up a new event loop for running async code
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    try:
        # Run the async function until complete and get the result
        result = loop.run_until_complete(calc_async())
        return result
    finally:
        # Close the loop to clean up resources
        loop.close()

# Example usage
result = sync_function()
print("Result from async function:", result)