Airflow DockerOperator-在正在运行的Docker容器中运行脚本

如何解决Airflow DockerOperator-在正在运行的Docker容器中运行脚本

我的问题很简单。

我想使用 DockerOperator 在容器内部运行python脚本，但是我不想拉出或运行该容器，因为我的目标容器已经存在（已经启动）。因此，我所期望的只是使用命令参数（ command =“ python my_python_script.py” ）

运行python脚本

with DAG('mydag',default_args=args,schedule_interval='@daily',catchup=False) as dag:

    task_1=DockerOperator(
        task_id='run_task1',image='ABCDFG',container_name="EFGHIJKL",api_version='auto',auto_remove=False,user="root",working_dir="/mydirt",command="python my_python_script.py",docker_url="unix://var/run/docker.sock"
        )

我已经尝试了不同的方法来执行此操作，但是到目前为止我仍未达到预期的结果。 在这种情况下，是否有人知道如何进行？我开始认为这是不可能的。