问题标签 [faust]

我正在尝试使用 Faust Stream 获得字节等回复。但它总是将回复编码为 sting（因为 faust 使用 json 编解码器进行回复）。是否可以像字节一样获得回复？

在这里，它bytes在侦听器中接收，say但它将str在值中，由返回ask

平台：Linux-4.15.0-1050-azure-x86_64-with-debian-stretch-sid

Python 3.7.3

浮士德：1.10.3

我正在尝试按照 faust [hello_world][1] 示例在我的 Mac 上工作。并得到以下错误：

令我惊讶的是以下错误。

1. macOS：卡特琳娜
2. python3.7

注意：我能够安装 kafka 并能够运行 zookeeper 和 kafka。但我觉得这与它无关。

我有一个简单的应用程序，具有两个功能，一个用于收听主题，另一个用于 Web 端点。我想创建服务器端事件流（SSE），即文本/事件流，以便在客户端我可以使用 EventSource 收听它。

我现在有以下代码，每个函数都在做它的特定工作：

现在，我想要在索引中，类似这样的代码，但使用浮士德：

我试过这个：

但它给了我以下错误：

我尝试过这个：

但我收到以下错误：

有没有办法做到这一点？提前非常感谢！

我正在尝试分析输入麦克风的声音并获取输入的频率值。

有没有我可以得到输入频率的库？

我正在使用浮士德。

谢谢

我正在尝试使用 pytest 为我的 Faust 应用程序编写单元测试。我在这里参考了文档，但它没有提到当我的浮士德代理向接收器发送数据时要做什么。

没有水槽，我的测试工作正常，但是当我使用水槽时，我得到了这个错误：

我尝试了各种方法：例如修补我的浮士德应用程序中将数据发送到接收器的装饰器，尝试在没有装饰器的情况下测试我的功能（通过尝试绕过它），修补我的浮士德应用程序中的接收器参数以有一个 None 值（所以它不会将我的数据发送到接收器）等。我对这些都没有运气。

这是我的浮士德代理：

这是我当前的测试代码：

运行此测试时，我得到与上述相同的错误。有什么方法可以成功测试我的 Faust 应用程序吗？

谢谢！

我有一个看起来像的 JSON 对象

我正在尝试将记录反序列化为

我可能遗漏了一些简单的东西，但是如何从键中有连字符的 json 对象转到 python 对象。任何帮助将非常感激！

我正在调试一个简单的应用程序：

并希望在重新启动此应用程序时让代理从最早的偏移量中读取。现在，它很聪明，知道最后一条消息的读取位置，并在重新启动时从该位置开始。尽管搜索了一段时间的文档，但我找不到如何执行此操作的示例。我知道如何做到这一点的唯一方法是更改​​应用程序名称，例如：更改app08为app09.

检查下面的代码

代理在 5 秒内异步获取 5000 条记录并进行处理。我不希望代理在前一个处理完成之前再选择 500 万条记录。基本上我想同步运行代理。有没有办法我们可以做到？

我正在寻找一种在浮士德代理中运行非异步库的好方法：

我阅读了 将 Faust 添加到您的现有架构的帖子， 我推断我们只需要在 faust 中使用 IO/Async 库。现在有办法将非异步库变成 faust 吗？我看到一些猴子用 : (gevent 和 eventlet) 修补，但似乎不起作用

我正在尝试将 Faust 与 Django 集成以将消息发布到 Kafka。这是浮士德仓库中的示例：https ://github.com/robinhood/faust/tree/master/examples/django

我对其进行了一些修改，并创建了视图以通过 Faust 将数据推送到 Kafka。

但是，我现在收到此错误：

RuntimeError at / Task <Task pending name='Task-1' coro=<AsyncToSync.main_wrap() running at /Users/mysuer/.pyenv/versions/3.8.3/envs/faustdjango/lib/python3.8/site- packages/asgiref/sync.py:204> cb=[_run_until_complete_cb() at /Users/mysuer/.pyenv/versions/3.8.3/lib/python3.8/asyncio/base_events.py:184]> 将 Future 附加到不同的循环

我正在使用开发服务器运行这个 Django 应用程序。我究竟做错了什么？任何人？:)