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

本條目是否有幫助?