Quick Start 快速开始

Project Podris is provided as a public welfare service. To prevent abuse, we require token authentication tied to a Tencent QQ account.
破灾实控是一项公益服务。为防止服务被滥用，我们采用令牌认证机制，且令牌须与您的腾讯 QQ 账号绑定。

Join the group chat (Group ID: 172185748) to review the token usage policy and obtain your token.
请加入群聊（群号：172185748），了解令牌使用规则后获取你的令牌。

Here is a classic Python 3 PSC client example. It implements core features including token-based authentication, real-time parsing and output of intelligence payloads, and exponential backoff for connection error handling.
这是一个基于 Python 3 的经典 PSC 客户端示例。它实现了令牌认证连接、实时解析并输出情报字典等核心功能，同时采用指数退避策略处理连接错误。

First, install the websockets module in your Python environment.
首先您需要在您的 Python 环境中安装 websockets 模块

Next, create a new Python script and paste the code below:
然后将以下内容复制到一个新的Python脚本文件中：

import asyncio
import websockets
import json
import base64
import brotli
import time

SERVER = "<PSC_ADDRESS>"
TOKEN = "<PSC_TOKEN>"

async def main():
    retry_count = 0  # Retry count
    while True:
        try:
            async with websockets.connect(f"ws://{SERVER}/stable?token={TOKEN}") as ws:
                while True:
                    raw = await ws.recv()
                    decoded = base64.b64decode(raw)  # Decode
                    decompressed = brotli.decompress(decoded)  # Decompress
                    data = json.loads(decompressed)

                    if "ver" in data:  # Handshake
                        latency = (time.time_ns() // 1_000_000) - data["time"]
                        print(f"[HANDSHAKE] Latency: {latency} ms | Server Version: {data['ver']}")
                        retry_count = 0  # Reset retry count on successful handshake
                        continue

                    print(f"Received: {data}")

        except Exception as e:
            print(f"ERROR: {e}")
            # Handle connection errors using exponential backoff
            retry_count = min(retry_count + 1, 8)  # Maximum retry limit
            sleep_time = 2 ** retry_count
            print(f"Retry count: [{retry_count}], sleeping {sleep_time} s")
            await asyncio.sleep(sleep_time)

if __name__ == "__main__":
    asyncio.run(main())

Save and run the script. If everything goes smoothly, you should see output similar to below:
保存并运行脚本。如果一切顺利，你将看到类似以下的输出：

[HANDSHAKE] Latency: 114ms | Server Version: 5.14

当 PSC 分发给您新情报时，程序应该会继续输出：
When PSC distributes new intelligence to you, the program should continue to output:

Received: {'msg_id': 0, 'event_id': 0, 'event_type': 'EQR', 'event_source': '中国地震台网[正式测定]', 'time': '2025-02-12 01:10:23', 'region': '西藏那曲市双湖县', 'location': [33.81, 89.15], 'magnitude': 3.9, 'mag_type': 'Ms', 'intensity': 6.0, 'int_type': 'CSIS', 'depth': 10, 'area_intensity': [], 'detail_link': 'https://www.ceic.ac.cn/'}

*以上输出均是示例，您实际得到的输出会有差异 The above outputs are examples, and the actual outputs you receive may vary.

In the previous example, your client passively waited for server pushes. But PSC also supports active data interfaces — you can send plain-text commands to request specific data at any time.
在上个示例中，你的客户端只是被动地等待服务器推送数据。但 PSC 也支持主动数据接口——你可以随时向服务器发送纯文本指令，请求特定的数据。

The following Python example demonstrates how to actively request the latest three earthquake records.
接下来的 Python 实例展示了如何主动请求最近的三条地震记录。

import asyncio
import websockets
import json
import base64
import brotli
import time

SERVER = "<PSC_ADDRESS>"
TOKEN = "<PSC_TOKEN>"

async def main():
    retry_count = 0  # Retry count
    while True:
        try:
            async with websockets.connect(f"ws://{SERVER}/stable?token={TOKEN}") as ws:
                # Wait for handshake
                raw = await ws.recv()
                decoded = base64.b64decode(raw)  # Decode
                decompressed = brotli.decompress(decoded)  # Decompress
                data = json.loads(decompressed)

                if "ver" in data:  # Handshake
                    latency = (time.time_ns() // 1_000_000) - data["time"]
                    print(f"[HANDSHAKE] Latency: {latency} ms | Server Version: {data['ver']}")
                    retry_count = 0  # Reset retry count on successful handshake

                # Request the latest 3 earthquake records
                await ws.send("get_eqlist 3")

                # Receive response
                raw = await ws.recv()
                decoded = base64.b64decode(raw)  # Decode
                decompressed = brotli.decompress(decoded)  # Decompress
                history = json.loads(decompressed)

                print(f"Received {len(history)} earthquake record(s):")
                for item in history:
                    evt = item.get("event_type", "N/A")
                    region = item.get("region", "N/A")
                    mag = item.get("magnitude", "N/A")
                    print(f"  - [{evt}] {region} M{mag}")

                # Exit after output
                break

        except Exception as e:
            print(f"ERROR: {e}")
            # Handle connection errors using exponential backoff
            retry_count = min(retry_count + 1, 8)  # Maximum retry limit
            sleep_time = 2 ** retry_count
            print(f"Retry count: [{retry_count}], sleeping {sleep_time} s")
            await asyncio.sleep(sleep_time)

if __name__ == "__main__":
    asyncio.run(main())

Save and run the script. If everything goes smoothly, you should see output similar to below:
保存并运行脚本。如果一切顺利，你将看到类似以下的输出：

[HANDSHAKE] Latency: 114 ms | Server Version: 5.14
Received 3 earthquake record(s):
  - [EQR] Location1 M1.1
  - [EEW] Location2 M4.5
  - [CMT] Location3 M1.4

*以上输出均是示例，您实际得到的输出会有差异 The above outputs are examples, and the actual outputs you receive may vary.