Any support for RabbitMQ ?

未关闭

#269 创建于 2019年8月26日 4 条评论 0 个 reaction 已指派 0 人在 GitHub 查看

还没有人认领这个 Issue。

评估

难度: 5/5
预计耗时: 一周以上
新手友好度: 20/100

Issue 类型: 功能
描述清晰度: 需要澄清
活跃度: 停滞
技术栈: python, rabbitmq
领域: distributed-systems, stream-processing

调研方向

Begin by reproducing the RabbitMQ -> Streamz -> Dask setup described in the issue and reviewing how Streamz currently accepts streaming inputs. The issue does not name files, entry points, tests, or a specific failure, so the desired integration behavior and completion criteria need to be clarified before implementation.

由索引模型根据 Issue 内容生成。

描述

I have RabbitMQ and I need to feed the streaming data for parallel execution.
So,I opted RabbitMQ-> Streamz -> Dask for this purpose. But I am facing problems for Rabbit-Streamz integration.
Any suggestions/solutions for this ?

主要语言: Python
星标: 1.3k
派生: 149
平均合并: 17 小时 39 分钟
30 天内合并 PR: 1

贡献指南

打开贡献指南

从这里开始

先读完整个 Issue，再读项目的贡献指南。
在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
Fork 仓库，在一个分支上完成修改。
提交 Pull Request，并在描述里引用这个 Issue 编号。

python-streamz/streamz 的其他 Issue

pkg_resources warning 未关闭

难度 3/5 1-2 天新手友好度 35/100

python-streamz/streamz#481 · 4 条评论 · 2025年6月23日创建
Combining the streamz.Stream.filenames() and streamz.Stream.from_textfile() using dask scatter? 未关闭

难度 5/5 一周以上新手友好度 25/100

python-streamz/streamz#480 · 2 条评论 · 2025年2月10日创建
Compile the code into c++ 未关闭

难度 5/5 一周以上新手友好度 20/100

python-streamz/streamz#479 · 1 条评论 · 2024年10月28日创建
Suggestions for improving code performance 未关闭

难度 5/5 一周以上新手友好度 20/100

python-streamz/streamz#478 · 6 条评论 · 2024年9月17日创建
Is streamz not maintained anymore? What happened to cuStreamz? 未关闭

难度 4/5 3-5 天新手友好度 10/100

python-streamz/streamz#476 · 17 条评论 · 2 个 reaction · 2024年4月28日创建

查看 python-streamz/streamz 的全部 Issue

相似的 Issue

slack-gif-creator: validate_gif() multiplies the last frame's duration by the frame count, so reported duration/fps are wrong (1.0s GIF reported as 1.8s) 未关闭

难度 2/5 1-3 小时新手友好度 75/100

anthropics/skills#1811 · 1 条评论 · 2026年9月23日创建
App fails to start with gradio 6 (allowed by `gradio>=5.49.1`) 未关闭

难度 2/5 1-3 小时新手友好度 75/100

speaches-ai/speaches#678 · 2026年9月23日创建
ModuleNotFoundError: No module named 'mcp.server.fastmcp'. 未关闭

bug

难度 2/5 1-3 小时新手友好度 75/100

datalayer/mcp-compose#42 · 2026年9月23日创建
import spacy fails with ModuleNotFoundError: No module named 'click' 未关闭

难度 2/5 1-3 小时新手友好度 75/100

conda-forge/spacy-feedstock#177 · 2026年9月23日创建
humaneval: extract_function_body corrupts a fenced body-only reply, so the same correct code scores INCORRECT fenced and CORRECT unfenced 未关闭

难度 2/5 1-3 小时新手友好度 70/100

UKGovernmentBEIS/inspect_evals#2523 · 2026年9月23日创建

更多 Python Issue