弃用¶

这是 Apache Airflow Provider 软件包最新版本中已弃用对象的摘要。

注意

这是一个实验性页面，可能不包含所有已弃用的实体。目前我们只显示类、函数、方法、属性等的弃用。将来会添加对参数弃用或参数值弃用的支持。

apache-airflow-providers-alibaba¶

AnalyticDBSparkBaseOperator.get_hook - 改用 hook 属性。
AnalyticDBSparkSensor.get_hook - 改用 hook 属性。
OSSKeySensor.get_hook - 改用 hook 属性。

apache-airflow-providers-amazon¶

AwsBaseAsyncHook - airflow.providers.amazon.aws.hook.base_aws.AwsBaseAsyncHook 已弃用，未来将被移除
BaseAsyncSessionFactory - airflow.providers.amazon.aws.hook.base_aws.BaseAsyncSessionFactory 已弃用，未来将被移除
QuickSightHook.sts_hook - QuickSightHook.sts_hook 属性已弃用，未来将被移除。此属性用于获取 AWS 账户 ID，请考虑改用 QuickSightHook.account_id
RedshiftAsyncHook - airflow.providers.amazon.aws.hook.base_aws.RedshiftAsyncHook 已弃用，未来将被移除
DataSyncOperator.get_hook - 改用 hook 属性。
EksCreateClusterOperator.eks_hook - eks_hook 属性已弃用，未来将被移除。请改用 hook 属性。
BatchSensor.get_hook - 改用 hook 属性。
DmsTaskBaseSensor.get_hook - 改用 hook 属性。
EmrBaseSensor.get_hook - 改用 hook 属性。
GlueCatalogPartitionSensor.get_hook - 改用 hook 属性。
GlueCrawlerSensor.get_hook - 改用 hook 属性。
QuickSightSensor.quicksight_hook - QuickSightSensor.quicksight_hook 属性已弃用，请改用 QuickSightSensor.hook 属性。
QuickSightSensor.sts_hook - QuickSightSensor.sts_hook 属性已弃用，以后将被移除。此属性用于获取 AWS 帐号 ID，请考虑改用 QuickSightSensor.hook.account_id
RedshiftClusterSensor.get_hook - 改用 hook 属性。
S3KeySensor.get_hook - 改用 hook 属性。
SageMakerBaseSensor.get_hook - 改用 hook 属性。
SqsSensor.get_hook - 改用 hook 属性。
StepFunctionExecutionSensor.get_hook - 改用 hook 属性。
BatchOperatorTrigger - 改用 BatchJobTrigger
BatchSensorTrigger - 改用 BatchJobTrigger
RdsDbInstanceTrigger - 此触发器已弃用，请使用其他 RDS 触发器，例如 RdsDbDeletedTrigger、RdsDbStoppedTrigger 或 RdsDbAvailableTrigger
AwsBaseHookMixin.region - region 已弃用，以后将被移除。请改用 region_name。

apache-airflow-providers-apache-beam¶

BeamPipelineTrigger - BeamPipelineTrigger 已弃用。请使用 BeamPythonPipelineTrigger。

apache-airflow-providers-apache-drill¶

DrillOperator - 请使用 airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator。

apache-airflow-providers-apache-druid¶

DruidCheckOperator - 请使用 airflow.providers.common.sql.operators.sql.SQLCheckOperator。

apache-airflow-providers-apache-livy¶

LivyOperator.get_hook - 改用 hook 属性。

apache-airflow-providers-cncf-kubernetes¶

add_pod_suffix - 此函数已弃用。请使用 add_unique_suffix
create_pod_id - 此函数已弃用。请使用 create_unique_id。
KubernetesPodOperator.execute_complete - 改用 trigger_reentry。
PodGenerator.add_xcom_sidecar - 此函数已弃用。请改用 airflow.providers.cncf.kubernetes.utils.xcom_sidecar.add_xcom_sidecar
PodGenerator.gen_pod - 此方法已弃用，将在将来的版本中移除
PodGenerator.make_unique_pod_id - 此方法已弃用。在 kubernetes_helper_functions 中使用 add_pod_suffix。
PodManager.follow_container_logs - 方法 follow_container_logs 已弃用。请改用 fetch_container_logs，并使用选项 follow=True。

apache-airflow-providers-databricks¶

DatabricksRunNowDeferrableOperator - DatabricksRunNowDeferrableOperator 已弃用。请改用 airflow.providers.databricks.operators.DatabricksRunNowOperator，并使用 deferrable=True。
DatabricksSubmitRunDeferrableOperator - DatabricksSubmitRunDeferrableOperator 已弃用。请改用 airflow.providers.databricks.operators.DatabricksSubmitRunOperator，并使用 deferrable=True。

apache-airflow-providers-dbt-cloud¶

DbtCloudJobRunAsyncSensor - 类 DbtCloudJobRunAsyncSensor 已弃用，且将在未来版本中移除。请改用 DbtCloudJobRunSensor，并将 deferrable 属性设为 True

apache-airflow-providers-docker¶

DockerOperator.get_hook - 改用 hook 属性。

apache-airflow-providers-elasticsearch¶

ElasticsearchHook - 请使用 airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchSQLHook。

apache-airflow-providers-fab¶

FabAirflowSecurityManagerOverride.oauth_whitelists - “oauth_whitelists”属性已弃用。请改用“oauth_allow_list”。

apache-airflow-providers-google¶

BigQueryBaseCursor.cancel_query - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.cancel_query
BigQueryBaseCursor.create_empty_dataset - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.create_empty_dataset
BigQueryBaseCursor.create_empty_table - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.create_empty_table
BigQueryBaseCursor.create_external_table - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.create_external_table
BigQueryBaseCursor.delete_dataset - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.delete_dataset
BigQueryBaseCursor.get_dataset - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.get_dataset
BigQueryBaseCursor.get_dataset_tables - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.get_dataset_tables
BigQueryBaseCursor.get_dataset_tables_list - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.get_dataset_tables_list
BigQueryBaseCursor.get_datasets_list - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.get_datasets_list
BigQueryBaseCursor.get_schema - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.get_schema
BigQueryBaseCursor.get_tabledata - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.get_tabledata
BigQueryBaseCursor.insert_all - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.insert_all
BigQueryBaseCursor.patch_dataset - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.patch_dataset
BigQueryBaseCursor.patch_table - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.patch_table
BigQueryBaseCursor.poll_job_complete - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.poll_job_complete
BigQueryBaseCursor.run_copy - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.run_copy
BigQueryBaseCursor.run_extract - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.run_extract
BigQueryBaseCursor.run_grant_dataset_view_access - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.run_grant_dataset_view_access
BigQueryBaseCursor.run_load - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.run_load
BigQueryBaseCursor.run_query - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.run_query
BigQueryBaseCursor.run_table_delete - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.run_table_delete
BigQueryBaseCursor.run_table_upsert - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.run_table_upsert
BigQueryBaseCursor.run_with_configuration - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.run_with_configuration
BigQueryBaseCursor.update_dataset - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.update_dataset
BigQueryHook.cancel_query - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.cancel_job
BigQueryHook.create_external_table - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.create_empty_table 方法，同时传递 table_resource 对象。这比此方法提供了更大的灵活性。
BigQueryHook.credentials_path - BigQueryHook.credentials_path 属性已弃用，将来会移除。此属性用于获取凭据路径，但不再实际使用。
BigQueryHook.get_dataset_tables_list - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.get_dataset_tables 方法。
BigQueryHook.get_service - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.get_client
BigQueryHook.get_tabledata - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.list_rows 方法。
BigQueryHook.patch_dataset - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.update_dataset 方法。
BigQueryHook.patch_table - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.update_table 方法。
BigQueryHook.run_copy - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.insert_job
BigQueryHook.run_extract - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.insert_job
BigQueryHook.run_load - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.insert_job
BigQueryHook.run_query - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.insert_job
BigQueryHook.run_table_delete - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.delete_table 方法。
BigQueryHook.run_with_configuration - 请使用 airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.insert_job
CloudBuildHook.create_build - 请使用 create_build_without_waiting_for_result
DataflowHook.start_java_dataflow - 此方法已弃用。请使用 airflow.providers.apache.beam.hooks.beam.start.start_java_pipeline 来启动管道，并使用 providers.google.cloud.hooks.dataflow.DataflowHook.wait_for_done 来等待所需的管道状态。
DataflowHook.start_python_dataflow - 此方法已弃用。请使用 airflow.providers.apache.beam.hooks.beam.start.start_python_pipeline 启动管道，并使用 providers.google.cloud.hooks.dataflow.DataflowHook.wait_for_done 等待所需的管道状态。
DataPipelineHook - 此挂钩已弃用，并将在 01.12.2024 之后删除。请使用 DataflowHook。
GKECustomResourceHook - GKECustomResourceHook 类已弃用，并将在 01.10.2024 之后删除，请改用 GKEKubernetesHook。
GKEDeploymentHook - GKEDeploymentHook 类已弃用，并将在 01.10.2024 之后删除，请改用 GKEKubernetesHook。
GKEHook.get_client - get_client 方法已弃用。您应该使用 get_conn 方法。
GKEHook.get_conn - get_conn 方法已弃用。您应该使用 get_cluster_manager_client 方法。
GKEJobHook - GKEJobHook 类已弃用，将在 01.10.2024 后移除，请改用 GKEKubernetesHook。
GKEPodAsyncHook - GKEPodAsyncHook 类已弃用，将在 01.10.2024 后移除，请改用 GKEKubernetesAsyncHook。
GKEPodHook - GKEPodHook 类已弃用，将在 01.10.2024 后移除，请改用 GKEKubernetesHook。
LifeSciencesHook - 此挂钩已弃用。考虑改用 Google Cloud Batch 运算符的挂钩。生命科学 API（测试版）将于 2025 年 7 月 8 日停用，转而使用 Google Cloud Batch。
SecretsManagerHook - SecretsManagerHook 已弃用，将在 01.11.2024 后移除。请改用 GoogleCloudSecretManagerHook。
CustomJobHook.cancel_pipeline_job - 请使用 PipelineJobHook.cancel_pipeline_job
CustomJobHook.create_pipeline_job - 请使用 PipelineJobHook.create_pipeline_job
CustomJobHook.delete_pipeline_job - 请使用 PipelineJobHook.delete_pipeline_job
CustomJobHook.get_pipeline_job - 请使用 PipelineJobHook.get_pipeline_job
CustomJobHook.list_pipeline_jobs - 请使用 PipelineJobHook.list_pipeline_jobs
AutoMLDatasetLink - 类 AutoMLDatasetLink 已弃用，并将在 31.12.2024 后移除。请改用 airflow/providers/google/cloud/links/translate.py 中的 TranslationLegacyDatasetLink。
AutoMLDatasetListLink - 类 AutoMLDatasetListLink 已弃用，并将在 31.12.2024 后移除。请改用 airflow/providers/google/cloud/links/translate.py 中的 TranslationDatasetListLink。
AutoMLModelLink - 类 AutoMLModelLink 已弃用，并将在 31.12.2024 后移除。请改用 airflow/providers/google/cloud/links/translate.py 中的 TranslationLegacyModelLink。
AutoMLModelPredictLink - 类 AutoMLModelPredictLink 已弃用，并将在 31.12.2024 后移除。请改用 airflow/providers/google/cloud/links/translate.py 中的 TranslationLegacyModelPredictLink。
AutoMLModelTrainLink - 类 AutoMLModelTrainLink 已弃用，且将在 31.12.2024 之后移除。请改用 airflow/providers/google/cloud/links/translate.py 中的 TranslationLegacyModelTrainLink。
BigQueryExecuteQueryOperator - 此操作符已弃用。请使用 BigQueryInsertJobOperator。
BigQueryPatchDatasetOperator - 此操作符已弃用。请使用 BigQueryUpdateDatasetOperator。
DataflowCreateJavaJobOperator - 请改用 providers.apache.beam.operators.beam.BeamRunJavaPipelineOperator。
DataflowCreatePythonJobOperator - 请改用 providers.apache.beam.operators.beam.BeamRunPythonPipelineOperator。
DataFusionPipelineLinkHelper.get_project_id - 请改用 airflow.providers.google.cloud.utils.helpers.resource_path_to_dict。
CreateDataPipelineOperator - 此操作已弃用，并将在 01.12.2024 后移除。请使用 DataflowCreatePipelineOperator。
RunDataPipelineOperator - 此操作已弃用，并将在 01.12.2024 后移除。请使用 DataflowRunPipelineOperator。
DataprocScaleClusterOperator - 请改用 DataprocUpdateClusterOperator。
DataprocSubmitHadoopJobOperator - 请改用 DataprocSubmitJobOperator。您可以使用 generate_job 方法生成表示您作业的字典，并将其与新操作一起使用。
DataprocSubmitHiveJobOperator - 请改用 DataprocSubmitJobOperator。您可以使用 generate_job 方法生成表示您作业的字典，并将其与新操作一起使用。
DataprocSubmitPigJobOperator - 请改用 DataprocSubmitJobOperator。你可以使用 generate_job 方法生成表示作业的字典，并将其与新操作符一起使用。
DataprocSubmitPySparkJobOperator - 请改用 DataprocSubmitJobOperator。你可以使用 generate_job 方法生成表示作业的字典，并将其与新操作符一起使用。
DataprocSubmitSparkJobOperator - 请改用 DataprocSubmitJobOperator。你可以使用 generate_job 方法生成表示作业的字典，并将其与新操作符一起使用。
DataprocSubmitSparkSqlJobOperator - 请改用 DataprocSubmitJobOperator。你可以使用 generate_job 方法生成表示作业的字典，并将其与新操作符一起使用。
GKEStartPodOperator.get_gke_config_file - 请改用 fetch_cluster_info 来获取集群信息以连接到它。
LifeSciencesRunPipelineOperator - 考虑改用 Google Cloud Batch 运算符。生命科学 API（测试版）将于 2025 年 7 月 8 日停止使用，转而使用 Google Cloud Batch。
MLEngineCreateModelOperator - 此运算符已弃用。所有旧版 MLEngine 的功能和新功能均可在 Vertex AI 平台上使用。请使用适当的 VertexAI 运算符。
MLEngineCreateVersionOperator - 此运算符已弃用。所有旧版 MLEngine 的功能和新功能均可在 Vertex AI 平台上使用。请改用 VertexAI 运算符的 parent_model 参数。
MLEngineDeleteModelOperator - 此运算符已弃用。所有旧版 MLEngine 的功能和新功能均可在 Vertex AI 平台上使用。请使用 DeleteModelOperator
MLEngineDeleteVersionOperator - 此运算符已弃用。所有旧版 MLEngine 的功能和新功能均可在 Vertex AI 平台上使用。请使用 DeleteModelVersionOperator
MLEngineGetModelOperator - 此操作符已弃用。旧版 MLEngine 的所有功能和新功能均可在 Vertex AI 平台上使用。请使用 GetModelOperator
MLEngineListVersionsOperator - 此操作符已弃用。旧版 MLEngine 的所有功能和新功能均可在 Vertex AI 平台上使用。请使用 ListModelVersionsOperator
MLEngineManageModelOperator - 此操作符已弃用。请考虑对特定操作使用操作符：MLEngineCreateModelOperator、MLEngineGetModelOperator。
MLEngineManageVersionOperator - 此操作符已弃用。请考虑对特定操作使用操作符：MLEngineCreateVersion、MLEngineSetDefaultVersion、MLEngineListVersions、MLEngineDeleteVersion。
MLEngineSetDefaultVersionOperator - 此操作符已弃用。旧版 MLEngine 的所有功能和新功能均可在 Vertex AI 平台上使用。请使用 SetDefaultVersionOnModelOperator
MLEngineStartBatchPredictionJobOperator - 此操作符已弃用。旧版 MLEngine 的所有功能和新功能均可在 Vertex AI 平台上使用。请使用 CreateBatchPredictionJobOperator
MLEngineStartTrainingJobOperator - 此操作已弃用。旧版 MLEngine 的所有功能和新功能均可在 Vertex AI 平台上使用。请使用 CreateCustomPythonPackageTrainingJobOperator
MLEngineTrainingCancelJobOperator - 此操作已弃用。旧版 MLEngine 的所有功能和新功能均可在 Vertex AI 平台上使用。请使用 CancelCustomTrainingJobOperator
DeleteAutoMLTrainingJobOperator.training_pipeline - training_pipeline 已弃用，未来将被移除。请改用 training_pipeline_id。
DeleteCustomTrainingJobOperator.custom_job - custom_job 已弃用，未来将被移除。请改用 custom_job_id。
DeleteCustomTrainingJobOperator.training_pipeline - training_pipeline 已弃用，未来将被移除。请改用 training_pipeline_id。
CloudSecretManagerBackend.get_conn_uri - 方法 CloudSecretManagerBackend.get_conn_uri 已弃用，并将在将来的版本中移除。请改用方法 get_conn_value。
BigQueryTableExistenceAsyncSensor - 类 BigQueryTableExistenceAsyncSensor 已弃用，并将在将来的版本中移除。请改用 BigQueryTableExistenceSensor，并将 deferrable 属性设置为 True
BigQueryTableExistencePartitionAsyncSensor - 类 BigQueryTableExistencePartitionAsyncSensor 已弃用，并将在将来的版本中移除。请改用 BigQueryTablePartitionExistenceSensor，并将 deferrable 属性设置为 True
CloudComposerEnvironmentSensor - CloudComposerEnvironmentSensor 运算符已弃用。你可以通过在可延迟或不可延迟模式下使用运算符来实现相同的功能，因为 Cloud Composer 的每个运算符都会等待操作完成。
GCSObjectExistenceAsyncSensor - 类 GCSObjectExistenceAsyncSensor 已弃用，并将在将来的版本中移除。请改用 GCSObjectExistenceSensor，并将 deferrable 属性设置为 True
GoogleBaseHook.client_info - 请使用 airflow.providers.google.common.consts.CLIENT_INFO。
GoogleAnalyticsHook - GoogleAnalyticsHook 类已弃用，请改用 GoogleAnalyticsAdminHook。
GoogleAnalyticsDataImportUploadOperator - GoogleAnalyticsDataImportUploadOperator 类已弃用，请改用 GoogleAnalyticsAdminCreateDataStreamOperator。
GoogleAnalyticsDeletePreviousDataUploadsOperator - GoogleAnalyticsDeletePreviousDataUploadsOperator 类已弃用，请改用 GoogleAnalyticsAdminDeleteDataStreamOperator。
GoogleAnalyticsGetAdsLinkOperator - GoogleAnalyticsGetAdsLinkOperator 类已弃用，请改用 GoogleAnalyticsAdminGetGoogleAdsLinkOperator。
GoogleAnalyticsListAccountsOperator - GoogleAnalyticsListAccountsOperator 类已弃用，请改用 GoogleAnalyticsAdminListAccountsOperator。
GoogleAnalyticsRetrieveAdsLinksListOperator - GoogleAnalyticsRetrieveAdsLinksListOperator 类已弃用，请改用 GoogleAnalyticsAdminListGoogleAdsLinksOperator。

apache-airflow-providers-hashicorp¶

VaultBackend.get_conn_uri - 方法 VaultBackend.get_conn_uri 已弃用，且将在未来版本中移除。

apache-airflow-providers-http¶

SimpleHttpOperator - 类 SimpleHttpOperator 已弃用，且将在未来版本中移除。请改用 HttpOperator。

apache-airflow-providers-jdbc¶

JdbcOperator - 请使用 airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator。

apache-airflow-providers-jenkins¶

JenkinsJobTriggerOperator.get_hook - 改用 hook 属性。

apache-airflow-providers-microsoft-azure¶

AzureContainerInstanceHook.get_messages - get_messages() 已弃用。相关方法是 get_state()
AzureContainerInstanceHook.get_state_exitcode_details - get_state_exitcode_details() 已弃用。相关方法是 get_state()
AzureDataExplorerQueryOperator.get_hook - 请改用 hook 属性。
AzureBatchOperator.get_hook - 请改用 hook 属性。
AzureKeyVaultBackend.get_conn_uri - 方法 AzureKeyVaultBackend.get_conn_uri 已弃用，且将在未来版本中移除。请改用方法 get_conn_value。
WasbBlobAsyncSensor - 类 WasbBlobAsyncSensor 已弃用，且将在未来版本中移除。请改用 WasbBlobSensor 并将 deferrable 属性设置为 True
AzureBlobStorageToGCSOperator - 请使用 airflow.providers.google.cloud.transfers.azure_blob_to_gcs.AzureBlobStorageToGCSOperator。

apache-airflow-providers-microsoft-mssql¶

MsSqlOperator - 请使用 airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator。此外，您可以提供 hook_params={‘schema’: <database>}。

apache-airflow-providers-mysql¶

MySqlOperator - 请使用 airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator。此外，您可以提供 hook_params={‘schema’: <database>}。

apache-airflow-providers-openlineage¶

AirflowMappedTaskRunFacet - 将在下一个版本中移除。请确保使用 AirflowRunFacet 中的信息。
UnknownOperatorAttributeRunFacet - 将在下一个版本中移除。请确保使用 AirflowRunFacet 中的信息。
normalize_sql - airflow.providers.openlineage.utils.utils.normalize_sql 已弃用，将在未来版本中移除

apache-airflow-providers-oracle¶

OracleOperator - 请使用 airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator。

apache-airflow-providers-pagerduty¶

PagerdutyHook.create_event - 此方法将被弃用。请使用 airflow.providers.pagerduty.hooks.PagerdutyEventsHook 与事件 API 交互
PagerdutyEventsHook.create_event - 此方法将被弃用。请使用 PagerdutyEventsHook.send_event 与事件 API 交互

apache-airflow-providers-postgres¶

PostgresHook.schema - “schema”变量已重命名为“database”，因为它包含数据库名称。请使用“database”获取数据库名称。
PostgresHook.schema - “schema”变量已重命名为“database”，因为它包含数据库名称。请使用“database”设置数据库名称。
PostgresOperator - 请使用 airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator。此外，您可以提供 hook_params={‘schema’: <database>}。

apache-airflow-providers-slack¶

SlackHook.send_file - 此方法利用 Slack API 方法 files.upload，该方法将于 2025 年 3 月 11 日停止使用。从 2024 年 5 月 8 日开始，新创建的应用将无法“files.upload”Slack API。请改用 send_file_v2 或 send_file_v1_to_v2。
SqlToSlackOperator - airflow.providers.slack.transfers.sql_to_slack.SqlToSlackOperator 已重命名并移动 airflow.providers.slack.transfers.sql_to_slack_webhook.SqlToSlackWebhookOperator，此操作员已弃用，将来将被移除
SqlToSlackWebhookOperator.slack_conn_id - SqlToSlackWebhookOperator.slack_conn_id 属性已弃用，将来将被移除。请改用 slack_webhook_conn_id。

apache-airflow-providers-snowflake¶

SnowflakeOperator - 此类已弃用。请使用 airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator。此外，您可以提供 hook_params={‘warehouse’: <warehouse>, ‘database’: <database>, ‘role’: <role>, ‘schema’: <schema>, ‘authenticator’: <authenticator>,’session_parameters’: <session_parameters>}。

apache-airflow-providers-sqlite¶

SqliteOperator - 请使用 airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator。

apache-airflow-providers-ssh¶

SSHHook.create_tunnel - SSHHook.create_tunnel 已弃用，请改用 get_tunnel()。但请注意，参数的顺序已更改。此方法将在 Airflow 2.0 中删除
SSHOperator.exec_ssh_client_command - SSHOperator 上的 exec_ssh_client_command 方法已弃用，请改用调用 ssh_hook.exec_ssh_client_command
SSHOperator.get_hook - 请改用 hook 属性。

apache-airflow-providers-trino¶

TrinoOperator - 请使用 airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator。

apache-airflow-providers-vertica¶

VerticaOperator - 请使用 airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator。

apache-airflow-providers-weaviate¶

WeaviateHook.get_client - get_client 方法已重命名为 get_conn