We have upgraded the plan of pubsub to Standard tier and we are currently monitoring the application. When our pubsub was in free tier, the problem occurred atleast once daily.
Below the post function handles the POST /connected webhook endpoint
class ConnectedEventHandlerView(APIView):
def post(self, request):
user_id = request.headers["Ce-Userid"]
connection_id = request.headers["Ce-Connectionid"]
try:
users = User.objects.filter(pk=user_id)
if users:
user = users[0]
pubsub_group_name = create_own_pubsub_group(user)
response = pubsub_service_client.send_request(
build_add_user_to_group_request(
settings.AZURE_PUBSUB_HUB_NAME,
pubsub_group_name,
user_id,
)
)
if response.status_code == 200:
return Response()
else:
local_logger.error(
f"status code {response.status_code}, response body {response.text}"
)
logger.error(
f"Could not add connection to groups. user_id {user_id}, connection_id f{connection_id}"
)
raise Exception("Could not add connection to groups")
except:
response = pubsub_service_client.send_request(
build_close_client_connection_request(
settings.AZURE_PUBSUB_HUB_NAME, connection_id
)
)
return Response(status=400)