从 Airflow 调用 Java 类或方法

如何解决从 Airflow 调用 Java 类或方法

我想从 Airflow 任务中调用几个 java 方法，因为我已经有很多用 java 编写的代码，包括验证、清理、一些业务逻辑，我不想再次用 Python 重写。>

我使用的是 Airflow 2.1.0

我知道有一种方法可以使用 BashOperator 调用 jar

jar_task = BashOperator(
    task_id='java',bash_command='java -jar somejar.jar',dag=dag
) 

但是有什么方法可以让我直接从任务本身调用任何特定的 Java 类或方法，否则我必须为我的每个逻辑创建许多小 jar。
提前致谢。

解决方法

您可以使用 java -cp somejar.jar SomeClass 来运行不同的 main 方法。