ibm-sample-stt2.py

import json
from os.path import join, dirname
from ibm_watson import SpeechToTextV1
from ibm_watson.websocket import RecognizeCallback, AudioSource
import threading
from ibm_cloud_sdk_core.authenticators import IAMAuthenticator

authenticator = IAMAuthenticator('EVbgkVy_v-9PfBfZvHukYnW9bbq1-OGen1qA4taporwV')
service = SpeechToTextV1(authenticator=authenticator)
service.set_service_url('https://api.us-south.speech-to-text.watson.cloud.ibm.com/instances/a2fb20ab-8b68-4ba2-b88a-34a972e0afa3')  # Replace <service_url> with your service URL


models = service.list_models().get_result()
print(json.dumps(models, indent=2))

model = service.get_model('en-US_BroadbandModel').get_result()
print(json.dumps(model, indent=2))
# Save transcriptions to a JSON file
output_file = 'transcriptions.json'


with open(join(dirname(__file__), '/Users/shan/Documents/Assets Backup/Watsonx-Support Ticket Insights/combined_audio.wav'),
          'rb') as audio_file:
    
        # json.dump(data, f, indent=4)
        response=json.dumps(service.recognize(
                                    audio=audio_file,
                                    content_type='audio/wav').get_result(),
                                    indent=2)
        print(json.dumps(
            service.recognize(
                audio=audio_file,
                content_type='audio/wav').get_result(),
            indent=2))
        
        with open(output_file, 'w') as f:
            json.dump(response, f, indent=4)

# # Example using websockets
# class MyRecognizeCallback(RecognizeCallback):
#     def __init__(self):
#         RecognizeCallback.__init__(self)

#     def on_transcription(self, transcript):
#         print(transcript)

#     def on_connected(self):
#         print('Connection was successful')

#     def on_error(self, error):
#         print('Error received: {}'.format(error))

#     def on_inactivity_timeout(self, error):
#         print('Inactivity timeout: {}'.format(error))

#     def on_listening(self):
#         print('Service is listening')

#     def on_hypothesis(self, hypothesis):
#         print(hypothesis)

#     def on_data(self, data):
#         print(data)

# # Example using threads in a non-blocking way
# mycallback = MyRecognizeCallback()
# audio_file = open(join(dirname(__file__), '../resources/speech.wav'), 'rb')
# audio_source = AudioSource(audio_file)
# recognize_thread = threading.Thread(
#     target=service.recognize_using_websocket,
#     args=(audio_source, "audio/l16; rate=44100", mycallback))
# recognize_thread.start()