quokka

环境要求

• Redis 版本需大于 6.2（Quokka 强依赖）
• Python 环境，可使用 pip3 安装包
• Debian/Ubuntu 系系统可使用 apt 安装 Redis（README 给出的命令基于此）
• 能访问 PyPI 下载 pyquokka

安装与启动步骤

1. 1安装最新 Redis

   README 强调系统默认 apt 源里的 Redis 版本很可能不满足要求，需先添加 Redis 官方 APT 仓库再安装。

   curl -fsSL https://packages.redis.io/gpg | sudo gpg --dearmor -o /usr/share/keyrings/redis-archive-keyring.gpg
   echo "deb [signed-by=/usr/share/keyrings/redis-archive-keyring.gpg] https://packages.redis.io/deb $(lsb_release -cs) main" | sudo tee /etc/apt/sources.list.d/redis.list
   sudo apt-get update
   sudo apt-get install redis

   复制

2. 2确认 Redis 版本

   安装完成后必须执行版本检查，确保 Redis Server 版本大于 6.2，否则 Quokka 无法正常工作。

   redis-server -v

   复制

3. 3安装 pyquokka

   通过 PyPI 安装 Quokka 的 Python 包 pyquokka，README 未指定额外参数，直接安装即可。

   pip3 install pyquokka

   复制

4. 4本地验证 DataStream

   用 Polars DataFrame 创建本地 DataStream 做冒烟测试，能打印出 DataStream 即说明依赖链路正常。

   from pyquokka import QuokkaContext
   import polars
   
   qc = QuokkaContext()
   a = polars.from_dict({"a":[1,1,2,2], "b":['{"my_field": "quack"}','{"my_field": "quack"}','{"my_field": "quack"}','{"my_field": "quack"}']})
   b = qc.from_polars(a)
   print(b)

   复制

如何确认成功

在 Python 中执行 from pyquokka import QuokkaContext 并打印 qc.from_polars(a) 的结果，输出类似 DataStream[a,b] 即成功。

常见问题

注意事项

• README 只给出 Debian/Ubuntu 的 Redis 安装命令，其他系统需自行准备符合版本的 Redis。
• Quokka 依赖 Redis 运行，使用前需保证 Redis 服务处于启动状态。
• README 未列出具体配置项与端口参数，如需进阶配置请查阅官方文档 https://marsupialtail.github.io/quokka/。
• 项目迭代较快，安装前可先浏览官方文档确认最新用法。