Airflow Operators

Airflow operators are core components of any workflow defined in airflow. The operator represents a single task that runs independently without sharing any information. Operators can execute various actions such as python function, bash command, SQL query, triggering API, sending email, and performing conditional operations. In airflow documentation, operator and task terms are used interchangeably. Tasks used to manage the execution of an operator in a DAG.

Tasks and operator

Types of Airflow Operators

Airflow has a wide variety of built-in operators that can perform the required operation such as python function, bash command, SQL query, triggering API, sending email, and performing conditional operations. Let's see a few examples of airflow operators:

• BashOperator: It is used to execute a bash command
• PythonOperator: It is used to run the python callable or python function.
• EmailOperator: It is used to send emails to the receiver
• MySqlOperator: It is used to run the SQL query for MySql Database.
• S3ToHiveOperator: It transfers data from Amazon S3 to Hive.