airflow.contrib.hooks.gcp_speech_to_text_hook

Module Contents

class airflow.contrib.hooks.gcp_speech_to_text_hook.GCPSpeechToTextHook(gcp_conn_id='google_cloud_default', delegate_to=None)

Bases: airflow.contrib.hooks.gcp_api_base_hook.GoogleCloudBaseHook

Hook for Google Cloud Speech API.

Parameters

• gcp_conn_id (str) – The connection ID to use when fetching connection info.

• delegate_to (str) – The account to impersonate, if any. For this to work, the service account making the request must have domain-wide delegation enabled.

_client

get_conn(self)

Retrieves connection to Cloud Speech.

Returns

Google Cloud Speech client object.

Return type

google.cloud.speech_v1.SpeechClient

recognize_speech(self, config, audio, retry=None, timeout=None)

Recognizes audio input

Parameters

• config (dict or google.cloud.speech_v1.types.RecognitionConfig) – information to the recognizer that specifies how to process the request. https://googleapis.github.io/google-cloud-python/latest/speech/gapic/v1/types.html#google.cloud.speech_v1.types.RecognitionConfig

• audio (dict or google.cloud.speech_v1.types.RecognitionAudio) – audio data to be recognized https://googleapis.github.io/google-cloud-python/latest/speech/gapic/v1/types.html#google.cloud.speech_v1.types.RecognitionAudio

• retry (google.api_core.retry.Retry) – (Optional) A retry object used to retry requests. If None is specified, requests will not be retried.

• timeout (float) – (Optional) The amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.