擅长:python、mysql、java
<p>您可以使用<code>-c '{"key":"value"}'</code>从CLI传递参数,然后在Python可调用函数中将其用作<code>"dag_run.conf["key"]"</code></p>
<p>就你而言</p>
<p><strong>操作员</strong>:</p>
<pre><code>PythonOperator(
task_id = 'task_identifier',
python_callable = 'run_task',
provide_context=True,
dag = this_dag
)
</code></pre>
<p><strong>可调用函数</strong>:</p>
^{pr2}$