如何在 Python 3 asyncio 中实现同步等待回调？

Question

由于一些不寻常的限制，我需要在返回响应之前同步等待来自另一个服务的回调 URL。目前我有类似的东西：

ROUTE = '/operation'
async def post(self):
    ##SOME OPERATIONS##
    post_body = { 'callbackUrl' : 'myservice.com/cb' }
    response = await other_service.post('/endpoint')
    global my_return_value
    my_return_value = None
    while not my_return_value:
        pass
    return self.make_response(my_return_value)

然后我有一种方法来处理回调 URL，例如：

ROUTE = '/cb'
async def post(self):
    ##OPERATIONS###
    global my_return_value
    my_return_value = some_value
    return web.json_response()

此代码的问题在于，即使调用了回调 URL，它也会永远被困在 while 循环中。我怀疑有更好的方法可以做到这一点，但我不知道如何去做，也不知道如何用谷歌搜索它。有什么想法吗？

提前致谢！

Answer 1

只是快速扫描，但我认为你被困在里面了

while not my_return_value:
    pass

Python 会被困在那里，没有时间处理回调函数。你需要的是

while not my_return_value:
    await asyncio.sleep(1)

（或者如果您不想要毫秒延迟，您甚至可以发送asyncio.sleep(0)）。

更好的方法是（现在我是凭记忆写的，不能保证......）：

my_return_value = asyncio.get_event_loop().create_future()
await my_return_value
return self.make_response(my_return_value.result())


async def post(self):
    ##OPERATIONS###
    my_return_value.set_result(some_value)
    return web.json_response()

但是请注意，如果该系统有多个并发使用，则任何一种方式都会非常糟糕。感觉非常脆弱！也许更好：

ROUTE = '/operation'
my_return_value = {}

async def post(self):
    ##SOME OPERATIONS##
    token = "%016x" % random.SystemRandom().randint(0, 2**128)
    post_body = { 'callbackUrl' : 'myservice.com/cb?token='+token }
    response = await other_service.post('/endpoint')
    my_return_value[token] = asyncio.get_event_loop().create_future()
    await my_return_value[token]
    result = my_return_value[token].result()
    del my_return_value[token]
    return self.make_response(result)

async def post(self):
    ##OPERATIONS###
    token = self.arguments("token")
    my_return_value[token].set_result(some_value)
    return web.json_response()

现在，cherry on top 将是一个计时器，它会在超时后取消未来，并在一段时间后清理 my_return_value 中的条目，如果回调没有发生。另外，如果您同意我的最后一个建议，请不要将其称为 my_return_value，而是将其称为 callback_future_by_token...