airflow.providers.google.cloud.transfers.salesforce_to_gcs¶

类¶

SalesforceToGcsOperator

提交 Salesforce 查询并将结果上传到 Google Cloud Storage。

模块内容¶

class airflow.providers.google.cloud.transfers.salesforce_to_gcs.SalesforceToGcsOperator(*, query, bucket_name, object_name, salesforce_conn_id, include_deleted=False, query_params=None, export_format='csv', coerce_to_timestamp=False, record_time_added=False, gzip=False, gcp_conn_id='google_cloud_default', **kwargs)[source]¶

基类: airflow.models.BaseOperator

提交 Salesforce 查询并将结果上传到 Google Cloud Storage。

另请参阅

有关如何使用此操作符的更多信息，请参阅以下指南: SalesforceToGcsOperator

参数:

query (str) – 要向 Salesforce 发出的查询。
bucket_name (str) – 要上传到的存储桶。
object_name (str) – 上传文件时要设置的对象名称。
salesforce_conn_id (str) – 连接到 Salesforce 所需参数的连接名称。
include_deleted (bool) – 如果查询应包含已删除记录，则为 True。
query_params (dict | None) – 其他可选参数。
export_format (str) – 要导出的文件的所需格式。
coerce_to_timestamp (bool) – 如果希望所有日期时间字段转换为 Unix 时间戳，则为 True。如果希望它们保持与 Salesforce 中相同的格式，则为 False。将此值保留为 False 将导致日期时间为字符串。默认值: False
record_time_added (bool) – 如果希望在结果数据中添加一个 Unix 时间戳字段，标记从 Salesforce 获取数据的时间，则为 True。默认值: False
gzip (bool) – 上传时压缩本地文件或文件数据的选项。
gcp_conn_id (str) – 连接到 GCS 所需参数的连接名称。

template_fields: collections.abc.Sequence[str] = ('query', 'bucket_name', 'object_name')[source]¶

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

template_fields_renderers[source]¶

query[source]¶

bucket_name[source]¶

object_name[source]¶

salesforce_conn_id[source]¶

export_format = 'csv'[source]¶

coerce_to_timestamp = False[source]¶

record_time_added = False[source]¶

gzip = False[source]¶

gcp_conn_id = 'google_cloud_default'[source]¶

include_deleted = False[source]¶

query_params = None[source]¶

execute(context)[source]¶

创建操作符时派生。

上下文与渲染 jinja 模板时使用的字典相同。

请参阅 get_template_context 获取更多上下文信息。