Merge pull request #286975 from valindrae/real-time-transcription-update

Update real-time-transcription-python.md

Author: Jill Grant

articles/communication-services/how-tos/call-automation/includes/real-time-transcription-python.md

@@ -93,44 +93,44 @@ After the metadata, the next packets your websocket receives will be Transcripti
 import asyncio
 import json
 import websockets
-
-from azure.communication.callautomation.streaming.models import (
-    TranscriptionMetadata, TranscriptionData, WordData, TextFormat, ResultStatus
-)
-from azure.communication.callautomation.streaming.streaming_data_parser import StreamingDataParser
+from azure.communication.callautomation._shared.models import identifier_from_raw_id
 
 async def handle_client(websocket, path):
     print("Client connected")
     try:
         async for message in websocket:
-            print(message)
-            result = StreamingDataParser.parse(message)
-            
-            if isinstance(result, TranscriptionMetadata):
-                print("Parsed data is metadata")
+            json_object = json.loads(message)
+            kind = json_object['kind']
+            if kind == 'TranscriptionMetadata':
+                print("Transcription metadata")
                 print("-------------------------")
-                print("Subscription ID:", result.subscriptionId)
-                print("Locale:", result.locale)
-                print("Call Connection ID:", result.callConnectionId)
-                print("Correlation ID:", result.correlationId)
-            
-            elif isinstance(result, TranscriptionData):
-                print("Parsed data is transcription data")
+                print("Subscription ID:", json_object['transcriptionMetadata']['subscriptionId'])
+                print("Locale:", json_object['transcriptionMetadata']['locale'])
+                print("Call Connection ID:", json_object['transcriptionMetadata']['callConnectionId'])
+                print("Correlation ID:", json_object['transcriptionMetadata']['correlationId'])
+            if kind == 'TranscriptionData':
+                participant = identifier_from_raw_id(json_object['transcriptionData']['participantRawID'])
+                word_data_list = json_object['transcriptionData']['words']
+                print("Transcription data")
                 print("-------------------------")
-                print("Text:", result.text)
-                print("Format:", result.format)
-                print("Confidence:", result.confidence)
-                print("Offset:", result.offset)
-                print("Duration:", result.duration)
-                print("Participant:", result.participant.raw_id)
-                print("Result Status:", result.resultStatus)
-                for word in result.words:
-                    print("Word:", word.text)
-                    print("Offset:", word.offset)
-                    print("Duration:", word.duration)
-
+                print("Text:", json_object['transcriptionData']['text'])
+                print("Format:", json_object['transcriptionData']['format'])
+                print("Confidence:", json_object['transcriptionData']['confidence'])
+                print("Offset:", json_object['transcriptionData']['offset'])
+                print("Duration:", json_object['transcriptionData']['duration'])
+                print("Participant:", participant.raw_id)
+                print("Result Status:", json_object['transcriptionData']['resultStatus'])
+                for word in word_data_list:
+                    print("Word:", word['text'])
+                    print("Offset:", word['offset'])
+                    print("Duration:", word['duration'])
+            
     except websockets.exceptions.ConnectionClosedOK:
         print("Client disconnected")
+    except websockets.exceptions.ConnectionClosedError as e:
+        print("Connection closed with error: %s", e)
+    except Exception as e:
+        print("Unexpected error: %s", e)
 
 start_server = websockets.serve(handle_client, "localhost", 8081)