Update main.py

main.py

@@ -114,22 +114,42 @@ async def send_video_to_django(responseRetrieve: dict):
         final_django_url = responseRetrieve.get('metadata', {}).get('final_django_url')
         if final_django_url:
             logger.info(f"Sending video data to Django server: {final_django_url}")
-            async with httpx.AsyncClient() as client:
-                headers = {
-                    'Authorization': django_authorization_token,
-                }
-                logger.info(f"video_url: {responseRetrieve.get('video_url')}")
-                logger.info(f"bot_id: {responseRetrieve.get('bot_id')}")
-                logger.info(f"user_id: {responseRetrieve.get('metadata', {}).get('user_id', None)}")
-                logger.info(f"event_id: {responseRetrieve.get('metadata', {}).get('event_id', None)}")
-                data = {
-                    'video_url': responseRetrieve.get('video_url'),
-                    'bot_id': responseRetrieve.get('bot_id'),
-                    'user_id': responseRetrieve.get('metadata', {}).get('user_id', None),
-                    'event_id': responseRetrieve.get('metadata', {}).get('event_id', None),
-                }
-                response = await client.post(final_django_url, json=data, headers=headers)
-                logger.info(f"Status code (Django): {response.status_code}, Data: {response.text}")
+            # async with httpx.AsyncClient() as client:
+            #     headers = {
+            #         'Authorization': django_authorization_token,
+            #     }
+            #     logger.info(f"video_url: {responseRetrieve.get('video_url')}")
+            #     logger.info(f"bot_id: {responseRetrieve.get('bot_id')}")
+            #     logger.info(f"user_id: {responseRetrieve.get('metadata', {}).get('user_id', None)}")
+            #     logger.info(f"event_id: {responseRetrieve.get('metadata', {}).get('event_id', None)}")
+            #     data = {
+            #         'video_url': responseRetrieve.get('video_url'),
+            #         'bot_id': responseRetrieve.get('bot_id'),
+            #         'user_id': responseRetrieve.get('metadata', {}).get('user_id', None),
+            #         'event_id': responseRetrieve.get('metadata', {}).get('event_id', None),
+            #     }
+            
+            #     response = await client.post(final_django_url, json=data, headers=headers)
+            #     logger.info(f"Status code (Django): {response.status_code}, Data: {response.text}")
+
+            headers = {
+                'Authorization': django_authorization_token,
+            }
+            logger.info(f"video_url: {responseRetrieve.get('video_url')}")
+            logger.info(f"bot_id: {responseRetrieve.get('bot_id')}")
+            logger.info(f"user_id: {responseRetrieve.get('metadata', {}).get('user_id', None)}")
+            logger.info(f"event_id: {responseRetrieve.get('metadata', {}).get('event_id', None)}")
+            
+            data = {
+                'video_url': responseRetrieve.get('video_url'),
+                'bot_id': responseRetrieve.get('bot_id'),
+                'user_id': responseRetrieve.get('metadata', {}).get('user_id', None),
+                'event_id': responseRetrieve.get('metadata', {}).get('event_id', None),
+            }
+            
+            response = requests.post(json_data.get('final_django_url'), headers=headers, json=data)
+            logger.info(f"Status code (Django): {response.status_code}, Data: {response.text}")
+            
         else:
             logger.error("final_django_url not found in the video data.")