pathway

环境要求

• Python 3.10 或以上
• macOS 或 Linux 系统（其他系统需在虚拟机中运行）
• Docker（可选，用于容器化运行）

安装与启动步骤

1. 1安装 Pathway

   在 macOS 或 Linux 上使用 pip 安装最新版 Pathway 框架。注意 Python 版本需 3.10 及以上。

   pip install -U pathway

   复制

2. 2编写管道脚本

   新建脚本文件（如 main.py），导入 pathway 并搭建处理管道，最后调用 pw.run() 启动计算。

   import pathway as pw
   
   # 在这里编写你的处理管道
   
   pw.run()

   复制

3. 3本地运行脚本

   像普通 Python 脚本一样运行。内置监控面板可查看各连接器发送的消息数与系统延迟。

   python main.py

   复制

4. 4用 pathway 命令启动

   也可用 pathway 包装命令启动，原生支持多线程；用 --threads 指定线程数，例如 3 个线程。

   pathway spawn --threads 3 python main.py

   复制

5. 5Docker 运行单文件

   单文件项目无需写 Dockerfile，直接挂载当前目录到 /app，用官方镜像执行脚本即可。

   docker run -it --rm --name my-pathway-app -v "$PWD":/app pathwaycom/pathway:latest python my-pathway-app.py

   复制

6. 6用 Dockerfile 构建

   也可基于标准 Python 镜像写 Dockerfile：安装 Pathway、拷贝脚本并设为启动命令。

   FROM --platform=linux/x86_64 python:3.10
   
   RUN pip install -U pathway
   COPY ./pathway-script.py pathway-script.py
   
   CMD ["python", "-u", "pathway-script.py"]

   复制

如何确认成功

脚本运行后终端无报错，且监控 dashboard 能显示各连接器的消息数量与系统延迟日志。

常见问题

注意事项

• Pathway 仅在 macOS 与 Linux 上可用，Windows 用户需借助虚拟机。
• pw.run() 是启动流式计算的必需调用，缺少它管道不会执行。
• 官方 Dockerfile 示例使用 platform 为 linux/x86_64 的 python:3.10 基础镜像。
• 更多示例代码可在项目仓库的 examples 目录中查看。