如何在 Python 3 中处理回调？

Question

我有一个自定义的 HTTP 方法/动词（比如说LISTEN），它允许我监听存储在远程服务器上的资源的更新。为此可用的 API 有一个阻塞调用，它将让我的客户端代码监听更新，直到我中断该调用的执行。举个例子，如果我要执行如下卷曲：

curl -X LISTEN http://<IP-Address>:<Port>/resource

执行此操作会创建一个阻塞调用，每当此资源的新值被推送到服务器时（类似于 pub-sub 模型），为我提供有关资源的更新，对此的响应将类似于以下内容：

{"data":"value update 1","id":"id resource"}
{"data":"value update 2","id":"id resource"}
(...)

如果我要在 Python 中编写代码来处理这个问题，我如何使用这个自定义动词调用我的 url 并处理阻塞调用/回调，同时确保这不会阻塞我其余代码的执行？

Answer 1

如果你使用 Python requests lib with a custom HTTP verb 和 need to read stream content，你可以这样做：

import json
import requests  # sudo pip3 install requests


url = "http://........."
r = requests.request('LISTEN', url, stream=True)
for line in r.iter_lines():
    # filter out keep-alive new lines
    if line:
        decoded_line = line.decode('utf-8')
        print(json.loads(decoded_line))

注意：默认情况下，所有requests 调用都是阻塞的，因此您需要在单独的线程/进程中运行此代码以避免这种情况。

...同时确保这不会阻止我其余代码的执行

由于您没有提供有关您的申请的详细信息，因此我将尝试列出一些关于问题的一般想法。

您的任务可以通过多种方式来解决。解决方案取决于您的应用架构。

如果这是一个网络服务器，您可以查看tornado（参见流式回调）或aiohttp 流式示例。

另一方面，您可以在单独的进程中运行上述代码，并使用 RabbitMQ（或其他 ipc 机制）与其他应用程序/服务进行通信。