airflow.providers.teradata.transfers.azure_blob_to_teradata¶
模块内容¶
类¶
将 CSV、JSON 和 Parquet 格式的数据从 Azure Blob 存储加载到 Teradata。 |
- class airflow.providers.teradata.transfers.azure_blob_to_teradata.AzureBlobStorageToTeradataOperator(*, blob_source_key, public_bucket=False, azure_conn_id='azure_default', teradata_table, teradata_conn_id='teradata_default', teradata_authorization_name='', **kwargs)[source]¶
基类：
airflow.models.BaseOperator将 CSV、JSON 和 Parquet 格式的数据从 Azure Blob 存储加载到 Teradata。
另请参阅
有关如何使用此操作符的更多信息，请查看指南： AzureBlobStorageToTeradataOperator
- 参数
blob_source_key (str) – 指定 Azure blob 对象存储位置的 URI 格式。(已模板化) URI 格式为 /az/YOUR-STORAGE-ACCOUNT.blob.core.windows.net/YOUR-CONTAINER/YOUR-BLOB-LOCATION。请参考 https://docs.teradata.com/search/documents?query=native+object+store&sort=last_update&virtual-field=title_only&content-lang=en-US
public_bucket (bool) – 指定提供的 blob 容器是否公开。如果 blob 容器是公开的，则意味着任何人都可以通过 URL 访问其中的对象，而无需进行身份验证。如果存储桶是私有的且未提供身份验证，则操作符将抛出异常。
azure_conn_id (str) – 用于 Azure blob 凭据的 Airflow WASB 连接。
teradata_table (str) – 数据传输到的 teradata 表的名称。(已模板化)
teradata_conn_id (str) – 用于连接到 Teradata 的连接 ID Teradata 连接
teradata_authorization_name (str) – Teradata 授权数据库对象的名称，用于控制谁可以访问 Azure Blob 对象存储。请参考 https://docs.teradata.com/r/Enterprise_IntelliFlex_VMware/Teradata-VantageTM-Native-Object-Store-Getting-Started-Guide-17.20/Setting-Up-Access/Controlling-Foreign-Table-Access-with-an-AUTHORIZATION-Object
请注意，
blob_source_key和teradata_table已模板化，因此如果需要，可以在其中使用变量。- template_fields: collections.abc.Sequence[str] = ('blob_source_key', 'teradata_table')[source]¶