问题标签 [pypubsub]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
wxpython - 混合使用 PyPubSub 和 wxPython 的内置 pubsub 模块
我有一个应用程序引擎，其中使用 PyPubSub 完成程序内通信。
Planned 是一个有点响应的 GUI，例如基于模型状态启用/禁用小部件。这将使用 wxPython 实现。
由于 wxPython 有一个在 GUI 上工作的自己的 pubsub 库（即 PyPubSub），问题是：如何维护 MVC 模型。
在保持 MVC 模式的同时混合两种消息传递系统是否可能（更重要的是：这是否有意义）？例如，让这两个消息传递系统分开，同时让 GUI 拥有引擎主题的订阅者？
或者我应该只在 GUI 中使用模型（即应用程序引擎）的 pubsub，而不使用 wxPython 内置的？
对这个相当概念性的问题的任何帮助表示赞赏。
python-3.x - 如何修复 wxPython 模块中的 wxPyDeprecationWarning 警告？
wxPython lib 中的一个弃用警告如下： wxPyDeprecationWarning: wx.lib.pubsub 已被弃用，请迁移您的代码以使用 pypubsub，在 PyPI 上可用。
python 3.7.2 和 pycharm IDE
python - pubsub 到 bigquery 没有使用 python 的数据流
我正在寻找执行代码以使用 python 代码从 pub sub 读取数据并存储到大表中。要求是不使用数据流选项。
您能否让我知道任何模板或示例代码来实现相同的目标。
提前致谢！。
publish-subscribe - Delivery_attempt 超过 max_delivery_attempts 后，PubSub 是否会将消息转发到死信主题
我的订阅者如下所示：
收到的消息如下所示：
显然它尝试了 5 次以上，为什么我仍然可以从 PubSub 主题中提取此消息？以下是订阅信息：
python - pypubsub 消息数据是通过引用还是值发送的，为什么我不应该修改消息数据
我正在使用 python 3。并且想知道附加到 pypubsub Sendmessage 命令的消息数据是通过引用还是通过值发送？它似乎是通过引用发送的，但我想知道是否有人可以验证这一点。
文档还说“消息不变性：侦听器必须保持消息内容不变，但 PyPubSub 不验证这一点”
下面的代码示例表明正在发送对消息数据参数的引用，并且修改这些数据会修改原始数据（而不是传递的数据副本）。为什么在侦听器例程中修改消息数据是个坏主意？
python - Python：带有线程的 PubSub 和 WxPython 是否需要 wx.CallAfter？
我在用：
wxPython 4.0.7.post2
Pypubsub 4.0.3
Python 3.8.1
我有以下我编写的示例程序：
我正在执行没有 wx.CallAfter 的 pub.sendMessage(TIME_UPDATED, seconds=time_elapsed) ，它似乎工作正常。我不确定为什么。
有人可以解释一下是否需要 wx.CallAfter 吗？
如果是，你能解释为什么会这样吗？是否某些 wx 方法将某些内容放入调度队列而其他方法没有？
python - wxpython Python 知道线程何时完成 -> 卡住
我正在继续我的计算机检查程序。它是基于 WXPYTHON 的。
该程序显示一个带有标签的界面和一个“运行”按钮，当单击该按钮时，它会在 mainFrame 类中启动“doCheck”函数
doCheck 然后启动所有线程：
线程正在执行一些 WMI 检查等并通过使用 pubsub.sendMessage() 报告 MainFrame 类具有一个侦听器函数，该函数在收到消息时更新 GUI 标签。
到目前为止，一切都很好！艾利斯运作良好。但是现在我想知道所有启动的线程何时完成。这就是问题所在......如果我在线程上使用 join()，则 PUBSUB GUI 更新在所有线程完成之前都不起作用。如果我在循环“isAlive()”的 doCheck 函数中使用 while 语句，它基本上会执行相同的操作，等待一切结束。同样，PUBSUB 也被停止了......
所以我被困在这里。到目前为止，该程序运行良好，但现在我需要在所有检查完成/完成后启动下一步，但我无法弄清楚如何在不阻止 PUBSUB 阻止运行时更新的情况下完成此操作......
实际线程的片段：
附言。message 参数用于知道应该更新哪些标签...
有什么建议么？我可以在需要时发布更多代码。
谢谢
python-3.x - pub.sendMessage 在我的代码中不起作用
运行以下类的代码后出现错误。暂时无解，求大神帮忙
pypubsub - Laravel 框架发布订阅
嗨，我已经通过 Laravel 框架中的作曲家安装了 google pubsub 库
$ 作曲家需要谷歌/云
这是 laravel 框架的正确库吗？有没有人使用过这个库并成功实现了 pubsub。
然后我创建了主题和订阅。订阅设置为推送。然后，当我尝试发布消息时，出现错误。在谷歌中，我找不到重复这样的错误。 这是我的代码。
python - Pub\Sub Python 客户端 - 优雅地关闭订阅者
我在 python3.6 中使用 Google Pub/Sub 客户端 v2.2.0 作为订阅者。
我希望我的应用程序在确认它已经收到的所有消息后正常关闭。
来自 Google 指南的订阅者的示例代码，稍作更改将显示我的问题：
来自https://cloud.google.com/pubsub/docs/pull
我希望此代码停止提取消息并完成正在运行的消息然后退出。
实际上，此代码停止提取消息并完成执行正在运行的消息，但它不确认消息。.ack() 发生但服务器没有收到 ack，所以接下来运行相同的消息再次返回。
1、为什么服务端收不到ack？
2. 如何优雅的关闭订阅者？
3. .cancel() 的预期行为是什么？