PyAPNs 和在发送之间休眠的需要
PyAPNs and the need to Sleep between Sends
我正在使用 PyAPNs 向 iOS 设备发送通知。我经常一次发送多组通知。如果任何令牌因任何原因损坏,该过程将停止。因此,我使用了增强设置和以下方法:
apns.gateway_server.register_response_listener
我用它来跟踪问题出在哪个令牌上,然后我从那里接收并发送其余令牌。问题是发送时捕获这些错误的唯一方法是在令牌发送之间使用睡眠定时器。例如:
for x in self.retryAPNList:
apns.gateway_server.send_notification(x, payload, identifier = token)
time.sleep(0.5)
如果我不使用睡眠计时器,则不会捕获任何错误,因此我的整个 APN 列表不会被发送到,因为当出现错误令牌时进程会停止。然而,这个睡眠定时器有些随意。有时 0.5 秒就足够了,而其他时候我不得不将其设置为 1。在任何情况下,如果不添加一些睡眠延迟,它就无法工作。这样做会减慢网络调用速度,并且进入随机睡眠时间感觉不那么可靠。
对于如何在 APN 调用之间没有延迟的情况下如何工作有任何建议,或者是否有针对所需延迟的最佳实践?
根据下面的要求添加更多代码。这是我用来控制它的 class 中的 3 种方法:
class PushAdmin(webapp2.RequestHandler):
retryAPNList=[]
channelID=""
channelName = ""
userName=""
apns = APNs(use_sandbox=True,cert_file="mycert.pem", key_file="mykey.pem", enhanced=True)
def devChannelPush(self,channel,name,sendAlerts):
ucs = UsedChannelStore()
pus = PushUpdateStore()
channelName = ""
refreshApnList = pus.getAPN(channel)
if sendAlerts:
alertApnList,channelName = ucs.getAPN(channel)
if not alertApnList: alertApnList=[]
if not refreshApnList: refreshApnList=[]
pushApnList = list(set(alertApnList+refreshApnList))
elif refreshApnList:
pushApnList = refreshApnList
else:
pushApnList = []
self.retryAPNList = pushApnList
self.channelID = channel
self.channelName = channelName
self.userName = name
self.retryAPNPush()
def retryAPNPush(self):
token = -1
payload = Payload(alert="A message from " +self.userName+ " posted to "+self.channelName, sound="default", badge=1, custom={"channel":self.channelID})
if len(self.retryAPNList)>0:
token +=1
for x in self.retryAPNList:
self.apns.gateway_server.send_notification(x, payload, identifier = token)
time.sleep(0.5)
下面是调用class(缩减无关项):
class ChannelStore(ndb.Model):
def writeMessage(self,ID,name,message,imageKey,fileKey):
notify = PushAdmin()
notify.devChannelPush(ID,name,True)
下面是我对睡眠计时器的位置所做的细微更改,似乎已经解决了这个问题。然而,我仍然担心所给予的时间是否在所有情况下都是正确的。
def retryAPNPush(self):
identifier = 1
token = -1
payload = Payload(alert="A message from " +self.userName+ " posted to "+self.channelName, sound="default", badge=1, custom={"channel":self.channelID})
if len(self.retryAPNList)>0:
token +=1
for x in self.retryAPNList:
self.apns.gateway_server.send_notification(x, payload, identifier = token)
time.sleep(0.5)
分辨率:
如底部评论所述,解决此问题的方法是将以下语句移至 class 之外的模块级别。通过这样做,不需要任何睡眠语句。
apns = APNs(use_sandbox=True,cert_file="mycert.pem", key_file="mykey.pem", enhanced=True)
事实上,PyAPNS 会自动为您重新发送丢失的通知,请参阅PyAPNS
所以你不必自己重试,你可以只记录哪些通知有坏令牌。
您的代码的行为可能是由于 APNS 对象保存在本地范围内(在 if len(self.retryAPNList)>0:
内)
我建议您将 APNS 对象拉出到 class 或模块级别,以便它可以完成其错误处理过程并重新使用 TCP 连接。
如果有帮助,请告诉我,谢谢:)
我正在使用 PyAPNs 向 iOS 设备发送通知。我经常一次发送多组通知。如果任何令牌因任何原因损坏,该过程将停止。因此,我使用了增强设置和以下方法:
apns.gateway_server.register_response_listener
我用它来跟踪问题出在哪个令牌上,然后我从那里接收并发送其余令牌。问题是发送时捕获这些错误的唯一方法是在令牌发送之间使用睡眠定时器。例如:
for x in self.retryAPNList:
apns.gateway_server.send_notification(x, payload, identifier = token)
time.sleep(0.5)
如果我不使用睡眠计时器,则不会捕获任何错误,因此我的整个 APN 列表不会被发送到,因为当出现错误令牌时进程会停止。然而,这个睡眠定时器有些随意。有时 0.5 秒就足够了,而其他时候我不得不将其设置为 1。在任何情况下,如果不添加一些睡眠延迟,它就无法工作。这样做会减慢网络调用速度,并且进入随机睡眠时间感觉不那么可靠。
对于如何在 APN 调用之间没有延迟的情况下如何工作有任何建议,或者是否有针对所需延迟的最佳实践?
根据下面的要求添加更多代码。这是我用来控制它的 class 中的 3 种方法:
class PushAdmin(webapp2.RequestHandler):
retryAPNList=[]
channelID=""
channelName = ""
userName=""
apns = APNs(use_sandbox=True,cert_file="mycert.pem", key_file="mykey.pem", enhanced=True)
def devChannelPush(self,channel,name,sendAlerts):
ucs = UsedChannelStore()
pus = PushUpdateStore()
channelName = ""
refreshApnList = pus.getAPN(channel)
if sendAlerts:
alertApnList,channelName = ucs.getAPN(channel)
if not alertApnList: alertApnList=[]
if not refreshApnList: refreshApnList=[]
pushApnList = list(set(alertApnList+refreshApnList))
elif refreshApnList:
pushApnList = refreshApnList
else:
pushApnList = []
self.retryAPNList = pushApnList
self.channelID = channel
self.channelName = channelName
self.userName = name
self.retryAPNPush()
def retryAPNPush(self):
token = -1
payload = Payload(alert="A message from " +self.userName+ " posted to "+self.channelName, sound="default", badge=1, custom={"channel":self.channelID})
if len(self.retryAPNList)>0:
token +=1
for x in self.retryAPNList:
self.apns.gateway_server.send_notification(x, payload, identifier = token)
time.sleep(0.5)
下面是调用class(缩减无关项):
class ChannelStore(ndb.Model):
def writeMessage(self,ID,name,message,imageKey,fileKey):
notify = PushAdmin()
notify.devChannelPush(ID,name,True)
下面是我对睡眠计时器的位置所做的细微更改,似乎已经解决了这个问题。然而,我仍然担心所给予的时间是否在所有情况下都是正确的。
def retryAPNPush(self):
identifier = 1
token = -1
payload = Payload(alert="A message from " +self.userName+ " posted to "+self.channelName, sound="default", badge=1, custom={"channel":self.channelID})
if len(self.retryAPNList)>0:
token +=1
for x in self.retryAPNList:
self.apns.gateway_server.send_notification(x, payload, identifier = token)
time.sleep(0.5)
分辨率:
如底部评论所述,解决此问题的方法是将以下语句移至 class 之外的模块级别。通过这样做,不需要任何睡眠语句。
apns = APNs(use_sandbox=True,cert_file="mycert.pem", key_file="mykey.pem", enhanced=True)
事实上,PyAPNS 会自动为您重新发送丢失的通知,请参阅PyAPNS
所以你不必自己重试,你可以只记录哪些通知有坏令牌。
您的代码的行为可能是由于 APNS 对象保存在本地范围内(在 if len(self.retryAPNList)>0:
内)
我建议您将 APNS 对象拉出到 class 或模块级别,以便它可以完成其错误处理过程并重新使用 TCP 连接。
如果有帮助,请告诉我,谢谢:)