airflow.providers.google.cloud.transfers.oracle_to_gcs¶

类¶

OracleToGCSOperator

将数据从 Oracle 复制到 Google Cloud Storage，格式为 JSON、CSV 或 Parquet。

模块内容¶

class airflow.providers.google.cloud.transfers.oracle_to_gcs.OracleToGCSOperator(*, oracle_conn_id='oracle_default', ensure_utc=False, **kwargs)[source]¶

继承自: airflow.providers.google.cloud.transfers.sql_to_gcs.BaseSQLToGCSOperator

将数据从 Oracle 复制到 Google Cloud Storage，格式为 JSON、CSV 或 Parquet。

另请参阅

有关如何使用此操作符的更多信息，请参阅指南： OracleToGCSOperator

参数:

oracle_conn_id – 对特定 Oracle hook 的引用。
ensure_utc – 确保 TIMESTAMP 列以 UTC 格式导出。如果设置为 False，TIMESTAMP 列将使用 Oracle 服务器的默认时区导出。

ui_color = '#a0e08c'[source]¶

type_map[source]¶

ensure_utc = False[source]¶

oracle_conn_id = 'oracle_default'[source]¶

query()[source]¶: 查询 Oracle 并返回结果的光标。

field_to_bigquery(field)[source]¶

将 DBAPI 字段转换为 BigQuery 模式格式。

convert_type(value, schema_type, **kwargs)[source]¶

获取 Oracle 数据库中的值，并将其转换为对 JSON/Google Cloud Storage/BigQuery 安全的值。

日期时间被转换为 UTC 秒。
小数被转换为浮点数。
如果 schema_type 是 DATE，日期被转换为 ISO 格式字符串；否则转换为 UTC 秒。
如果 schema_type 是 INTEGER，二进制类型字段被转换为整数；否则使用 base64 编码。根据 BigQuery 文档，导入的 BYTES 数据必须经过 base64 编码：https://cloud.google.com/bigquery/data-types

参数:

value – Oracle 数据库列值
schema_type – BigQuery 数据类型