擅长:python、mysql、java
<p>我绕过了插件步骤,用纯python的方式完成了它。这似乎也是最新版本(1.10.12)的文档所说的</p>
<p>这是我的文件夹结构:</p>
<pre><code>AIRFLOW_HOME
├── dags
│ ├── __init__.py
│ └── my_dag.py
└── utils
├── __init__.py
└── custom_operator.py
</code></pre>
<p>确保<code>PYTHONPATH</code>包含<code>AIRFLOW_HOME</code>路径。然后你可以像这样导入它:</p>
<pre><code>from custom_operator.hello_operator import HelloOperator
</code></pre>
<p>阅读更多信息:<a href="https://airflow.apache.org/docs/stable/howto/custom-operator.html#creating-a-custom-operator" rel="nofollow noreferrer">https://airflow.apache.org/docs/stable/howto/custom-operator.html#creating-a-custom-operator</a></p>