如何在 Django 中调用异步函数？

Question

以下不执行 foo 并给出 RuntimeWarning: coroutine 'foo' was never awaited

# urls.py

async def foo(data):
    # process data ...

@api_view(['POST'])
def endpoint(request):
    data = request.data.get('data')
    
    # How to call foo here?
    foo(data)

    return Response({})

Answer 1

Django 是一种同步语言，但它支持异步行为。 分享代码 sn-p 可能会有所帮助。

    import asyncio
    from channels.db import database_sync_to_async

    def get_details(tag):
        response = another_sync_function()

        # Creating another thread to execute function
        loop = asyncio.new_event_loop()
        asyncio.set_event_loop(loop)
        async_result = loop.run_until_complete(remove_tags(response, tag))
        loop.close()

    # Async function 
    async def remove_tags(response, tag_id):
        // do something here

        # calling another function only for executing database queries
        await tag_query(response, tag_id)

   @database_sync_to_async
   def tag_query(response, tag_id):
        Mymodel.objects.get(all_tag_id=tag_id).delete()

这样我在同步函数中调用了异步函数。

Reference for database sync to async decorator

Answer 2

找到了一种方法。

在与urls.py 相同的目录中创建另一个文件bar.py。

# bar.py

def foo(data):
    // process data

# urls.py

from multiprocessing import Process
from .bar import foo

@api_view(['POST'])
def endpoint(request):
    data = request.data.get('data')

    p = Process(target=foo, args=(data,))
    p.start()

    return Response({})

Answer 3

您不能在这种情况下等待 foo。看到Django主要是一个同步库，它与异步代码的交互并不好。我能给它的最好建议是尽量避免在这里使用异步函数，或者使用另一种并发方法（即线程或多处理）。

注意：关于 Django 的同步特性给出了一个很好的答案，可以在这里找到：Django is synchronous or asynchronous?。