擅长:python、mysql、java
<p>我们不需要创建文件夹<code>plugin</code>和添加<code>custom operators</code>。使用Airflow 2.0+,我们只需要在项目中创建一个文件夹并将其导入dag文件中</p>
<pre><code>airflow_project
+ custom_operator
+ first_operator.py
+ dags
+ dag_1.py
</code></pre>
<p>在dag_1.py中,可以将自定义操作符/挂钩作为以下内容导入:</p>
<pre><code>from custom_operator.first_operator import FirstOperator
</code></pre>