リアルタイム

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 のイベントを受け取るとカウントはリセットされます
• API の制限 (アプリごとに 5 秒に 1 回のオープン) を下回るよう、各再オープンは前回のオープンから最低 5.5 秒空けて行われます

​

制限とエラー

• 同時接続数は、全ユーザー合計でアカウントごとに 5、アプリごとに 30 です。超過すると 429 REALTIME_MAX_CONNECTIONS または REALTIME_MAX_CONNECTIONS_APP になります。
• HTTP ステータスはストリーミングの前にチェックされるため、これらのエラー (および不明なアプリに対する 404) は最初の反復で送出されます。
• タイムアウトは、レスポンスヘッダーが届くまでのオープン処理のみが対象です。ストリーム自体にタイムアウトはありません。半開きの接続 (スリープから復帰したノート PC など) は、close() を呼び出すまで待ち続けます。