问题标签 [python-pulsar]

尝试使用Django python pulsar并发处理框架。

提供的wsgi服务器pulsar可以通过命令行使用

它基本上启动了一个 HTTP WSGI 服务器，类似于 django 的开发服务器。

如何使用带有 mod_wsgi 的 Apache 网络服务器设置它？

我正在尝试将 RESTful 响应程序集成到 Crossbar 应用程序中，最合适的似乎是WSGI service。理想情况下，该服务应该是发布/订阅基础设施其余部分的一部分，一方面能够接收WAMP事件，另一方面能够响应 HTTP 请求。

困难在于运行允许异步 Web 套接字事件并另外提供 WSGI 兼容组件的事件循环。在我看来，Pulsar应该能够做到这一点，但我无法弄清楚如何设置它，没有可用的示例准确地展示了这个用例。

上面演示了两个部分，一个 Autobahn WAMP 客户端和一个 Flask WSGI 组件。如何并行运行这两者，允许一个线程通过 HTTP 和 Web 套接字接收事件？我并不特别关心 Python 的版本或底层库（Twisted、asyncio、Pulsar、Flask），我只是想让它以某种方式运行。

我正在使用 Tornado 编写应用程序。我需要发出很多 HTTP 请求，但是 Tornado 的 HTTP 客户端有点糟糕（没有 Keep-Alive 支持而且速度很慢），所以我尝试使用 Pulsar HttpClient：

当发生超时时，我得到一个异常：

我能以某种方式捕捉到这个异常吗？

我目前正在寻找pulsar一个异步 HTTP 客户端。

以下示例在文档中：

但是当我尝试执行它时，我得到了

似乎async无法识别该关键字。我正在使用 Python 3.5。

工作示例：

我目前有一个docker-compose.yml文件，它带来了许多服务。其中一个服务是 pulsar，另一个是通过 websocket 连接的网络服务器。当我启动这些服务时，websocket 容器不起作用。它的日志说：Error Checking/Getting Partition Metadata while Subscribing on persistent://public/default/test。我没有使用分区，所以我很难弄清楚这一点。

到目前为止，我已经做了很多谷歌搜索，发现这个问题没有答案，但看起来与我的问题相似。

这是我的docker-compose.yml文件：

当我检查两者的日志时ios_pos_ws_input，ios_pos_ws_sink我看到了：

我真的很想弄清楚这一点。我提前感谢任何帮助！

我根本无法安装pulsar-client，因为它在文档中提到：

收集 pulsar-client 错误：找不到满足 pulsar-client 要求的版本（来自版本：无） 错误：没有找到 pulsar-client 的匹配分布

收集 pulsar-client==2.4.0 错误：找不到满足 pulsar-client==2.4.0 要求的版本（来自版本：无） 错误：没有找到 pulsar-client==2.4.0 的匹配分布

我在 Windows 10python 3版本上。

尝试了python2 和 3 版本。

pulsar-client通过运行以下步骤安装 python 时

遇到错误

没有这样的文件或目录：_pulsar.so

我配置了broker.conf并尝试创建一个启用了 tls 的客户端。从字面上看，我正确提供了证书路径。当我尝试运行客户端时，它显示以下错误。

这是我从 apache pulsar 文档中遵循的 broker.conf 身份验证配置。

似乎没有使用代理中的端口 6651 启动主机连接。我检查了只有端口 6650 对连接开放。它可以在不启用 TLS 的情况下正常工作。

提前感谢您的帮助。

谢谢你。

如Pulsar Schema Registry Docs中的示例所示

您可以使用 Java 客户端为生产者和消费者注册模式。还提到其他语言的客户端不支持模式注册表。

现在是否可以从 Python API 生产者发送关于 Pulsar 主题的消息，该消息将由具有注册模式的消费者使用？例如

Python：导入脉冲星

我需要有关 Pulsar 函数异常的帮助，什么是用户函数异常，如果它的速率/计数很高会发生什么，以及高速率/计数的原因。