修改 Python 的 Pubnub 存在心跳

Question

根据存在文档，Pubnub 将在未收到心跳 5 分钟后触发超时存在事件。 我需要修改此值，但我找不到使用 Python SDK 执行此操作的方法。以下是 Pubnub 文档的链接，展示了如何使用 JavaScript：http://www.pubnub.com/docs/web-javascript/presence#optimizing_timeout_events

有人知道如何使用 python SDK 实现这一点吗？

非常感谢。

编辑：我的客户不是 javascript 客户。它们是 python 控制台应用程序。

Answer 1

心跳可以通过猴子修补到 Pubnub 类中，如下所示：

from pubnub import Pubnub

class PubnubHeartbeat(Pubnub):
    def __init__(self, heartbeat=300, **kwargs):
        self.heartbeat = heartbeat
        super(PubnubHeartbeat, self).__init__(**kwargs)

    def getUrl(self, request):
        if "subscribe" in request['urlcomponents'][:2]:
            if "urlparams" not in request:
                request['urlparams'] = {}
            request['urlparams']['heartbeat'] = self.heartbeat

        return super(PubnubHeartbeat, self).getUrl(request)


p = PubnubHeartbeat(
    subscribe_key="demo",
    publish_key="demo",
    heartbeat=60
)

def recv(msg):
    print msg

p.subscribe(channels="heartbeat_test", callback=recv)

不建议将这用于长期生产代码（除非您在安装期间使用 pubnub==3.7.3 固定您的 Pubnub 依赖项）。示例子类使用未记录的方法来注入 heartbeat URL 参数。 （有关其作用的描述，请参见 Craig Conover 的回答）。

Answer 2

PubNub Python SDK 存在

由于 Python 很少用作 客户端，PubNub Python SDK 的 presence API 没有像 传统 客户端 SDK（JavaScript 等）那样健壮地实现。 ）。因此，Pubnbub 初始化程序中没有心跳参数，也没有 setter 或 attribute，因此您不得不坚持使用默认的 5 分钟心跳设置。

但是，对于 PubNub JavaScript SDK，当您使用自定义 heartbeat（例如 60 秒）初始化 PUBNUB 时，heartbeat 键/值只是作为 REST URL 中的查询参数传递：

http://pubsub.pubnub.com/subscribe/demo/my_channel/0/14411482999795083?uuid=12345&pnsdk=PubNub-JS-Web%2F3.7.14&heartbeat=60

因此，如果您真的愿意，您可以使用 REST 调用订阅并以这种方式传递 heartbeat。

我第一次发布此答案时忘记提及的是，您的客户端负责至少每 60 秒 ping PubNub 服务器一次，最好以 30 秒为间隔，这是服务器配置的 60 秒心跳窗口这个客户。

使用 PubNub SDK，这是通过同一连接在单独的线程中完成的（某种程度上 - 至少以服务器知道设置心跳的同一客户端的方式）。

也就是说，我们正在使用 REST 获得一个不那么简单的解决方案，所以为什么还要使用 SDK。对我们来说更新 Python SDK 比你做所有的脏活要容易。我们会这样做，但不是在短期内，但希望在 Python SDK 的下一个次要版本中。

根据我们的非 SO 对话，您只想缩短客户端看起来在线的时间窗口，而实际上客户端未连接并且在连接关闭之前无法显式取消订阅（关闭终端，而不是使用应用程序的 UI 或命令行“注销”）。

你可以做的是实现一个 ping/ack 握手协议。这是非常高的级别，因此可能需要填写一些更精细的点，但它应该提供一般概念。

• 在一个客户端（发送方）与另一个（接收方）进行通信之前，只需在客户端的 private 通道上向另一个客户端发送 ping 消息（每个客户端都会订阅该客户端独有的频道：例如，private_client001、private_client002 等）。
• 接收客户端将自动回复发送者的唯一通道（这将是 ping 消息负载的一部分）
• 如果 ping 的发送方在一秒钟内（或任何适合您的时间容限）内没有收到确认消息，则假定接收方不在线。
• 当接收方重新上线时，您会收到错过的消息，以及任何不到 5 分钟的 ping，您可以回复并查看发送方是否仍想参与。

这是许多用例（尤其是聊天）的常见问题，因为总有一个时间窗口（心跳窗口），客户端可能确实处于离线状态，但似乎在线，因为他们没有在适当的、可预测的时间内离开会产生显式unsubscribe 的时尚，从而导致leave 事件。所以实现这种握手预连接协议是一个很好的实践。