无法在Python中获得pubnub.time()的结果

问题描述 投票:1回答:1

如何在调用时获取pubnub.time()的结果?这绝对与我不完全了解python有关...

我正在尝试调用pubnub.time()来测试网络连接何时恢复,以便pubnub可以重新连接,我可以重新订阅必要的频道。我似乎无法获得所需的输出。根据pubnub docs,time()有3个方法将返回int,string或date。

envelope = pubnub.time()

envelope.int()  outputs error
envelope.str()  outputs error
envelope.date_time()  outputs error

我唯一可以上班的是print(envelope),它产生了<pubnub.endpoints.time.Time object at 0x75fb8f50>

我不会深入研究我在此尝试了多少次迭代,并请求帮助。

UPDATE

我们有几个远程系统,我们希望使用PubNub从连接到机器的硬件收集数据点。数据请求将进入,PubNub需要响应请求。我们的主要问题是这些远程位置具有非常不稳定的DSL,一次只能持续数小时到数天,而当我们的python应用程序仍在运行时,PubNub不会重新连接。尝试使用LINEAR和EXPONENTIAL的reconnect_policy都无法在互联网中断后重新连接。虽然小而短暂的停电会恢复。除此之外,PubNub非常适合这种设置。

这是我的设置配置

pnconfig = PNConfiguration()
pnconfig.subscribe_key = 'sub'
pnconfig.publish_key = 'pub'
pnconfig.reconnect_policy = 'PNReconnectionPolicy.EXPONENTIAL'
pnconfig.daemon = True
pnconfig.ssl = True

这是我们的订阅回电:

class MySubscribeCallback(SubscribeCallback):
    def presence(self, pubnub, presence):
        pass

    def status(self, pubnub, status):
        if status.is_error():
            logger.error("PN Error" + str(status.error_data.exception))

        if status.category == 
            PNStatusCategory.PNUnexpectedDisconnectCategory:
            logger.error("PN Unexpected Disconnect")
            pubnub.reconnect()
            pass

        elif status.category == PNStatusCategory.PNConnectedCategory:
            logger.info("PN Connected")

        elif status.category == PNStatusCategory.PNReconnectedCategory:
            logger.warning("PN Re-Connected")
            pubnub.subscribe().channels('devChannel').execute()
            pass

        elif status.category == PNStatusCategory.PNDecryptionErrorCategory:
            logger.error("PN Decryption Error")
            pass
python pubnub
1个回答
0
投票

PubNub SDK Reconnect on Network Error

PubNub SDK构建耐用,能够在不稳定的网络条件下维护套接字连接。虽然连接可能并不总是可用,但只要网络连接恢复,PubNub SDK就会自动重新创建套接字并下载任何错过的消息。 PubNub Python SDK应遵循这一理念。

在您的示例代码中,您似乎正在设置reconnect_policy。但是,您的代码将重新连接策略变量设置为'PNReconnectionPolicy.EXPONENTIAL'字符串而不是枚举PNReconnectionPolicy.EXPONENTIAL

尝试对代码进行以下修改以利用重新连接策略:

from pubnub.enums import PNReconnectionPolicy       ## <-- Import Enumerator
from pubnub.pnconfiguration import PNConfiguration

## ... init ...

## Set Reconnection Policy using Enumerator
pnconf.reconnect_policy = PNReconnectionPolicy.EXPONENTIAL

SDK的默认值为pnconf.reconnect_policy = PNReconnectionPolicy.NONE。另一个有效的选择是pnconf.reconnect_policy = PNReconnectionPolicy.LINEAR

设置为PNReconnectionPolicy.LINEAR以进行自动重新连接。使用选项PNReconnectionPolicy.NONE禁用自动重新连接。使用选项PNReconnectionPolicy.EXPONENTIAL设置指数重试间隔。

参考资料:https://github.com/pubnub/python/search?q=PNReconnectionPolicy&unscoped_q=PNReconnectionPolicy

文档资料:https://www.pubnub.com/docs/python/api-reference-configuration#configuration-args-1

© www.soinside.com 2019 - 2024. All rights reserved.