Google Cloud Translate Operators

Prerequisite Tasks

To use these operators, you must do a few things:

CloudTranslateTextOperator

Translate a string or list of strings.

For parameter definition, take a look at CloudTranslateTextOperator

Using the operator

Basic usage of the operator:

airflow/contrib/example_dags/example_gcp_translate.pyView Source

product_set_create = CloudTranslateTextOperator(
    task_id='translate',
    values=['zażółć gęślą jaźń'],
    target_language='en',
    format_='text',
    source_language=None,
    model='base',
)

The result of translation is available as dictionary or array of dictionaries accessible via the usual XCom mechanisms of Airflow:

airflow/contrib/example_dags/example_gcp_translate.pyView Source

translation_access = BashOperator(
    task_id='access',
    bash_command="echo '{{ task_instance.xcom_pull(\"translate\")[0] }}'"
)
product_set_create >> translation_access

Templating

template_fields = ('values', 'target_language', 'format_', 'source_language', 'model', 'gcp_conn_id')

Was this entry helpful?