airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake¶

类¶

OracleToAzureDataLakeOperator

针对 Oracle 运行查询，并将文件存储在本地，然后将其加载到 Azure Data Lake。

模块内容¶

class airflow.providers.microsoft.azure.transfers.oracle_to_azure_data_lake.OracleToAzureDataLakeOperator(*, filename, azure_data_lake_conn_id, azure_data_lake_path, oracle_conn_id, sql, sql_params=None, delimiter=',', encoding='utf-8', quotechar='"', quoting=csv.QUOTE_MINIMAL, **kwargs)[source]¶

基类: airflow.models.BaseOperator

针对 Oracle 运行查询，并将文件存储在本地，然后将其加载到 Azure Data Lake。

参数:

filename (str) – CSV 文件使用的文件名。
azure_data_lake_conn_id (str) – 目标 Azure Data Lake 连接。
azure_data_lake_path (str) – 文件在 Azure Data Lake 中的目标路径。
oracle_conn_id (str) – 源 Oracle 连接。
sql (str) – 针对 Oracle 数据库执行的 SQL 查询。（使用模板）
sql_params (dict | None) – SQL 查询中使用的参数。（使用模板）
delimiter (str) – 文件中的字段分隔符。
encoding (str) – 文件的编码类型。
quotechar (str) – 引用时使用的字符。
quoting (int) – 引用策略。更多信息请参阅 csv 库。

template_fields: collections.abc.Sequence[str] = ('filename', 'sql', 'sql_params')[source]¶

template_fields_renderers[source]¶

ui_color = '#e08c8c'[source]¶

filename[source]¶

oracle_conn_id[source]¶

sql[source]¶

sql_params = None[source]¶

azure_data_lake_conn_id[source]¶

azure_data_lake_path[source]¶

delimiter = ','[source]¶

encoding = 'utf-8'[source]¶

quotechar = '"'[source]¶

quoting = 0[source]¶

execute(context)[source]¶

创建 Operator 时派生。

Context 与渲染 jinja 模板时使用的字典相同。

有关更多 context，请参阅 get_template_context。