问题标签 [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.

0 投票
1 回答
55 浏览

model-view-controller - 控制器无法从 View PyPubsub 获取消息

嗨,我试图用 wxPython 和 PyPubsub 编写一个简单的 MVC 应用程序。在我的视图文件中,我使用带有一个字段的简单窗口向控制器发送消息,在此字段中,我输入了新用户的名称,当我点击“创建”按钮时,它应该发送带有名称的消息,但控制器没有收到此消息. 我做错了什么?

这是我的视图文件的一部分:

这是我的控制器:

0 投票
0 回答
257 浏览

redis - Reddis 返回“ERR 协议错误:请求中的引号不平衡”

我们正在开发需要将数据发送到云基础平台的物联网设备。我使用 redis pubsub 实时调整数据。一个设备设置我们收到前3个数据包然后我收到错误REDIS“ERR协议错误:请求中的不平衡引号”
我使用查看redis文档的命令监控我的端口tcpdump port 443 它说端口上没有设置计时器使用redis pusub。请注意,我从 iot 设备发送的数据是一个 RESP 数组,它具有以下示例

RESP = "*3\r\n$7\r\nPUBLISH\r\n$%d\r\n%s\r\n$%d\r\n%s\r\n" % ( len(CHANNEL ), 频道, len(消息), 消息)

消息是json格式

鉴于我使用 utf-8 编码但从设备接收到 3 个数据包然后它失败,我如何解决从简单的 python 客户端发送这样的问题没有问题。设备必须重新加载再次发送 3 个数据包然后连接丢失。可能是什么问题

0 投票
1 回答
77 浏览

python-3.x - 使用 pypubsub & wxpython 在出现 TypeError 的窗口之间传输数据:

我正在尝试使用 PyPubSub 在两个 wxpython 窗口之间传递数据。下面我已经削减了基础的代码。当我在主窗口的 textcntrl 中填写数据并点击按钮将其传递到第二个窗口(CoordFrame)时,我得到了以下错误 -

TypeError:sendMessage() 接受 2 个位置参数,但给出了 3 个

我能找到的每个示例都显示在 pub.sendMessage 中传递了两个参数;这就是我认为我正在做的事情。传递的第三个参数是什么,它是从哪里来的,我该如何阻止它?我尝试了各种参数组合和包括二进制在内的数据类型。

'''

'''

0 投票
1 回答
126 浏览

python - Python 多线程与 pypubsub 和 wx

我有一个结构如下的程序:

在此处输入图像描述

GUI是用 wxPython 制作的,位于主线程中。启动应用程序后,GUI 线程Thread1创建一个静态类Class1,该类创建一个Thread2.

Thread1 使用 与 GUI 对话wx.PostEvent,一切正常。我还需要 Thread1 与 Thread2 进行通信,所以我决定使用 pyPubSub 来实现。Thread2 需要在后台工作,因为它包含一些定期执行的操作,但它还包含my_func()Thread1 需要在某些事件上调用的函数(比方说)。我决定放入my_func()Thread2 是因为我不希望它停止 Thread1 的执行,但这正是发生的事情:在 Thread1 中,在我pub.sendMessage("events", message="Hello")用来触发的一些事件之后my_func();Thread2 的结构如下:

Thread2 的父级是 Class1,所以当我在 Class1 中创建线程时,我会:

为什么 Thread2 会停止 Thread1 的执行?

0 投票
1 回答
40 浏览

wxpython - 如何在 wxpython 中侦听帧大小/移动更改事件

在 wxpython 中发布.listen 大小更改事件的正确方法是什么?

我确信这很简单,但我不知道如何在类之间很好地实现它(请原谅任何新手明显的错误)。

我可以使用 pypubsub 发送事件,但这仅在创建 UI 类时被侦听器捕获(即侦听一次,而不是在随后调整框架大小时)。

听众:

出版商:

我试过使用 CallAfter - 但这似乎没有帮助(不太确定我在用这个做什么,但认为它可能会在之后调用事件)

我还尝试了 CallAfter 的第二种变体,它似乎被听了两次(一种改进?),但我理解这是由结果 AssertionError 错误地格式化

在此先感谢您的任何帮助/指点

最小演示:

0 投票
1 回答
211 浏览

python - 使用 Python 将 Pub/Sub 消息加载到 BigQuery

我正在尝试使用 python 提取 Pub/Sub 消息并加载到 BigQuery 的消息。我可以提取消息,但无法将其加载到 BigQuery。这是一个编写的代码示例。您知道如何使用 python 将此消息加载到 BigQuery。

0 投票
1 回答
44 浏览

python - WxPython PyPubSub,使用咖喱函数不起作用

我正在使用 , 的PyPubSub模块WxPython来发送消息,并且我希望有一个订阅主题的函数,其中该函数有一些咖喱参数。不幸的是,它似乎没有像我期望的那样使用咖喱函数。

我得到的错误是:

那么如何将侦听器函数传递给主题,该函数至少包含一个参数?显然还有其他方法可以做到这一点(一个全局变量),但我觉得这应该可以通过部分函数来实现。

0 投票
0 回答
41 浏览

google-cloud-platform - GCP Pub/Sub 主题的本地测试权限 (IAM)

我有一个用例,我想在本地测试 GCP Pub/Sub 主题的权限 (IAM)。官方文档提供了一个示例代码。

我正在尝试使用 pub/sub 模拟器在本地测试我的应用程序,但它有一些限制(不实现权限)。

有人可以帮我知道 - 我如何在本地测试权限?我需要为此编写单元测试和集成测试。