实时

with client.apps.realtime(app_id) as stream:
    for event in stream:
        if event["event"] == "logs":
            print(event["stream"], event["line"])  # "stdout" | "stderr"
        elif event["event"] == "status":
            print(event["status"].get("cpu"), event["status"].get("ram"))  # always the full, merged state
        else:
            print(event["event"], event["data"])  # "system" or "error"

async with client.apps.realtime(app_id) as stream:  # no await: realtime() is not a coroutine
    async for event in stream:
        if event["event"] == "logs":
            print(event["stream"], event["line"])  # "stdout" | "stderr"
        elif event["event"] == "status":
            print(event["status"].get("cpu"), event["status"].get("ram"))  # always the full, merged state
        else:
            print(event["event"], event["data"])  # "system" or "error"

​

事件

​

status 对象

​

结束流

• 服务器正常关闭连接（每个连接最长持续 10 分钟）；
• 服务器发送 REALTIME_DISCONNECTED；
• 你使用 break 跳出循环（随后离开 with 代码块，从而关闭连接）；
• 你从任意线程调用 stream.close()，即使循环正在等待数据或重新连接（循环直接结束，不会抛出异常）。

import threading

stream = client.apps.realtime(app_id)
threading.Timer(60, stream.close).start()  # stop after one minute

for event in stream:
    print(event["event"], event["data"])

​

重新连接

• 最多连续 3 次；任何 logs 或 status 事件都会重置计数；
• 每次重新打开距上一次打开至少 5.5 秒，以保持在 API 每个应用每 5 秒打开一次的速率之内。

​

限制和错误

• 每个账户 5 个并发连接，每个应用 30 个（涵盖所有用户）。超出时返回 429 REALTIME_MAX_CONNECTIONS 或 REALTIME_MAX_CONNECTIONS_APP。
• HTTP 状态会在开始流式传输之前检查，因此这些错误（以及未知应用的 404）会在第一次迭代时抛出。
• 超时只覆盖打开阶段，直到响应头到达为止。流本身没有超时：半开的连接（例如从睡眠中恢复的笔记本电脑）会一直等待，直到你调用 close()。