ASF: Apache 软件基金会

Airflow 支持由 Apache 软件基金会 创建的各种软件。

软件

这些集成允许您在 Apache 软件基金会开发的软件中执行各种操作。

Apache Beam

Operator:

airflow.providers.apache.beam.operators.beam.

Hook:

airflow.providers.apache.beam.hooks.beam.

指南:

Apache Beam Operator.

Provider:

apache-airflow-providers-apache-beam

产品文档:

Apache Beam

Apache Cassandra

Hook:

airflow.providers.apache.cassandra.hooks.cassandra.

Sensor:

airflow.providers.apache.cassandra.sensors.record, airflow.providers.apache.cassandra.sensors.table.

指南:

Apache Cassandra Operator.

Provider:

apache-airflow-providers-apache-cassandra

产品文档:

Apache Cassandra

Apache Drill

Hook:

airflow.providers.apache.drill.hooks.drill.

指南:

通过 SQLExecuteQueryOperator 连接到 Apache Drill.

Provider:

apache-airflow-providers-apache-drill

产品文档:

Apache Drill

Apache Druid

Operator:

airflow.providers.apache.druid.operators.druid.

Hook:

airflow.providers.apache.druid.hooks.druid.

指南:

用于连接到 Apache Druid 的 SQLExecuteQueryOperator.

Provider:

apache-airflow-providers-apache-druid

产品文档:

Apache Druid

Apache Hive

Operator:

airflow.providers.apache.hive.operators.hive, airflow.providers.apache.hive.operators.hive_stats.

Hook:

airflow.providers.apache.hive.hooks.hive.

Sensor:

airflow.providers.apache.hive.sensors.hive_partition, airflow.providers.apache.hive.sensors.metastore_partition, airflow.providers.apache.hive.sensors.named_hive_partition.

指南:

用于连接到 Apache Hive 的 SQLExecuteQueryOperator.

Provider:

apache-airflow-providers-apache-hive

产品文档:

Apache Hive

Apache Impala

Hook:

airflow.providers.apache.impala.hooks.impala.

Provider:

apache-airflow-providers-apache-impala

产品文档:

Apache Impala

Apache Kafka

Operator:

airflow.providers.apache.kafka.operators.consume, airflow.providers.apache.kafka.operators.produce.

Hook:

airflow.providers.apache.kafka.hooks.base, airflow.providers.apache.kafka.hooks.client, airflow.providers.apache.kafka.hooks.consume, airflow.providers.apache.kafka.hooks.produce.

Sensor:

airflow.providers.apache.kafka.sensors.kafka.

Provider:

apache-airflow-providers-apache-kafka

产品文档:

Apache Kafka

Apache Kylin

Operator:

airflow.providers.apache.kylin.operators.kylin_cube.

Hook:

airflow.providers.apache.kylin.hooks.kylin.

Provider:

apache-airflow-providers-apache-kylin

产品文档:

Apache Kylin

Apache Livy

Operator:

airflow.providers.apache.livy.operators.livy.

Hook:

airflow.providers.apache.livy.hooks.livy.

Sensor:

airflow.providers.apache.livy.sensors.livy.

指南:

Apache Livy Operator.

Provider:

apache-airflow-providers-apache-livy

产品文档:

Apache Livy

Apache Pig

Operator:

airflow.providers.apache.pig.operators.pig.

Hook:

airflow.providers.apache.pig.hooks.pig.

指南:

Apache Pig Operator.

Provider:

apache-airflow-providers-apache-pig

产品文档:

Apache Pig

Apache Pinot

Hook:

airflow.providers.apache.pinot.hooks.pinot.

指南:

用于连接到 Apache Pinot 的 SQLExecuteQueryOperator.

Provider:

apache-airflow-providers-apache-pinot

产品文档:

Apache Pinot

Apache Spark

Operator:

airflow.providers.apache.spark.operators.spark_jdbc, airflow.providers.apache.spark.operators.spark_sql, airflow.providers.apache.spark.operators.spark_submit.

Hook:

airflow.providers.apache.spark.hooks.spark_connect, airflow.providers.apache.spark.hooks.spark_jdbc, airflow.providers.apache.spark.hooks.spark_jdbc_script, airflow.providers.apache.spark.hooks.spark_sql, airflow.providers.apache.spark.hooks.spark_submit.

指南:

Apache Spark Operator.

Provider:

apache-airflow-providers-apache-spark

产品文档:

Apache Spark

标准

Operator:

airflow.providers.standard.operators.datetime, airflow.providers.standard.operators.weekday, airflow.providers.standard.operators.bash, airflow.providers.standard.operators.python, airflow.providers.standard.operators.empty, airflow.providers.standard.operators.trigger_dagrun, airflow.providers.standard.operators.latest_only, airflow.providers.standard.operators.smooth, airflow.providers.standard.operators.branch.

Hook:

airflow.providers.standard.hooks.filesystem, airflow.providers.standard.hooks.package_index, airflow.providers.standard.hooks.subprocess.

Sensor:

airflow.providers.standard.sensors.date_time, airflow.providers.standard.sensors.time_delta, airflow.providers.standard.sensors.time, airflow.providers.standard.sensors.weekday, airflow.providers.standard.sensors.bash, airflow.providers.standard.sensors.python, airflow.providers.standard.sensors.filesystem, airflow.providers.standard.sensors.external_task.

指南:

BashOperator, PythonOperator, BranchDateTimeOperator.

Provider:

apache-airflow-providers-standard

产品文档:

标准

WebHDFS

Hook:

airflow.providers.apache.hdfs.hooks.webhdfs.

Sensor:

airflow.providers.apache.hdfs.sensors.web_hdfs.

指南:

WebHDFS Operator.

Provider:

apache-airflow-providers-apache-hdfs

产品文档:

WebHDFS

传输

这些集成允许您在 Apache 软件基金会开发的软件之间复制数据。

Apache Hive 到 Amazon DynamoDB

源产品文档:

Apache Hive

目标产品文档:

Amazon DynamoDB

Operator 指南:

Apache Hive 到 Amazon DynamoDB

Python API:

airflow.providers.amazon.aws.transfers.hive_to_dynamodb

Provider:

apache-airflow-providers-amazon

Apache Hive 到 Apache Druid

源产品文档:

Apache Hive

目标产品文档:

Apache Druid

Python API:

airflow.providers.apache.druid.transfers.hive_to_druid

Provider:

apache-airflow-providers-apache-druid

Vertica 到 Apache Hive

源产品文档:

Vertica

目标产品文档:

Apache Hive

Python API:

airflow.providers.apache.hive.transfers.vertica_to_hive

Provider:

apache-airflow-providers-apache-hive

Apache Hive 到 MySQL

源产品文档:

Apache Hive

目标产品文档:

MySQL

Python API:

airflow.providers.apache.hive.transfers.hive_to_mysql

Provider:

apache-airflow-providers-apache-hive

Apache Hive 到 Samba

源产品文档:

Apache Hive

目标产品文档:

Samba

Python API:

airflow.providers.apache.hive.transfers.hive_to_samba

Provider:

apache-airflow-providers-apache-hive

Amazon Simple Storage Service (S3) 到 Apache Hive

源产品文档:

Amazon Simple Storage Service (S3)

目标产品文档:

Apache Hive

Python API:

airflow.providers.apache.hive.transfers.s3_to_hive

Provider:

apache-airflow-providers-apache-hive

MySQL 到 Apache Hive

源产品文档:

MySQL

目标产品文档:

Apache Hive

Python API:

airflow.providers.apache.hive.transfers.mysql_to_hive

Provider:

apache-airflow-providers-apache-hive

Microsoft SQL Server (MSSQL) 到 Apache Hive

源产品文档:

Microsoft SQL Server (MSSQL)

目标产品文档:

Apache Hive

Python API:

airflow.providers.apache.hive.transfers.mssql_to_hive

Provider:

apache-airflow-providers-apache-hive

Apache Cassandra 到 Google Cloud Storage (GCS)

源产品文档:

Apache Cassandra

目标产品文档:

Google Cloud Storage (GCS)

Python API:

airflow.providers.google.cloud.transfers.cassandra_to_gcs

Provider:

apache-airflow-providers-google

本条目是否有帮助?