Listening for Subscription Events in Python SDK

Question

question

prospect-health asked Feb 1, '23 prospect-health commented Feb 13, '23

Listening for Subscription Events in Python SDK

I originally had a webhook setup in Azure for receiving RingCentral event subscriptions, but this no longer works due to some issue with Azure HTTP functions being unable to handle chunked encoding in requests.

To replace the webhook, I have tried using the RingCentral SDK for Python to setup a PubNub subscription that listens for the same events. I have got it setup so that it successfully sets up the subscription and delivers the events to where I'm storing them. However, after a day or two of running the events stop feeding through or the script encounters a "subscription is not alive" exception and stops working.

Should I be able to just set the subscription running in a Python script and leave it for years uninterrupted or does there need to be some code added in to handle refreshing subscriptions/auth tokens etc. to make sure that it can receive all event subscriptions uninterrupted? It's quite important that I can leave it running for ages and that it doesn't ever miss any incoming events.

Here is the code that I am using (I'm not a pro-coder, I just dabble). Can anyone spot any issues with it or advise on what needs to be changed to get it working in the way that I want? If there's any recommended services outside of Azure for setting up a Python webhook as well, I would be all ears to that, as the webhook setup feels more robust to me. Thanks.

import time
import json
import requests
import pubnub
from threading import Thread
from ringcentral import SDK
from ringcentral.subscription import Events


sdk = SDK('CLIENTKEY', 'CLIENTSECRET', 'https://platform.ringcentral.com')
platform = sdk.platform()
platform.login('ACCOUNTNUMBER', 'EXTENSION', 'PASSWORD')

res = platform.get('/account/~/extension/~')


def on_message(msg):
     try:
          #write the data to storage
     except Exception as ex:
          #email me the exception traceback
          time.sleep(30)

def nubpub():
     try:
          s = sdk.create_subscription()
          s.add_events(['/account/ACCOUNTNUMBER/telephony/sessions'])
          s.on(Events.notification, on_message)
          s.register()
          while True:
               time.sleep(0.1)
     except Exception as ex:
          #email me the exception traceback
          time.sleep(30)

try:
       t = Thread(target=nubpub)
       t.start()
except Exception as ex:
       #email me the exception traceback

sdk authentication webhooks subscription pubnub

1 |3000

Attachments: Up to 8 attachments (including images) can be used with a maximum of 1.0 MiB each and 10.0 MiB total.

Using the RingCentral Phone for Desktop, you can dial or receive test calls, send and receive test SMS or Fax messages in your sandbox environment.

Download RingCentral Phone for Desktop:

Tip: switch to the "sandbox mode" before logging in the app:

On MacOS: press "fn + command + f2" keys
On Windows: press "Ctrl + F2" keys

Answer 1 · 2023-02-02T17:15:18Z

Phong Vu answered Feb 2, '23 prospect-health sent Feb 13, '23

Which line from your code print the error "subscription is not alive"? What is the purpose to sleep (30) within the exception?

Have you tried any of these instructions

https://learn.microsoft.com/en-us/answers/questions/971790/transfer-encoding-chunked-header-for-a-response-st

https://github.com/Azure/azure-functions-host/issues/4926

https://stackoverflow.com/questions/58527919/azure-function-how-to-received-data-via-chunked-encoding

1

1 |3000

Attachments: Up to 8 attachments (including images) can be used with a maximum of 1.0 MiB each and 10.0 MiB total.

prospect-health commented · Feb 13, 2023 at 02:47 PM

Thanks for these suggestions @Phong Vu .

I have looked through the links that you have provided, but it seems that the Azure webhook is now working again. Not sure if this is due to the change that your mentioned in this post: https://community.ringcentral.com/questions/112360/webhook-subscription-is-triggering-with-no-body.html?childToView=112792#answer-112792 If so, I'm assuming that it will stop working again sometime within the next month? I think that I will have to wait and see if this happens again before trying to apply some of the suggestions in the threads you linked.

To answer your question about my code, the exceptions that I included were in the hope that I would be able to catch any instance of the script failing and have it send me an email in those instances so that I could minimise the downtime. I included the "sleep(30)" line in case there were instances where the script was looping through exceptions, so that my inbox didn't get flooded with these exception emails. However, it appears that those catch blocks in my code don't catch the "subscription is not alive" state, as this message gets delivered straight to the shell output. This is the traceback that it displays:

0 ·

question