前言

在使用airflow的时候，还没有升级到2.0，官方给的也是实验API，不足以满足工作中的需要。因此对airflow1.10.6版本的进行了java封装

一、airflow的java工具类

public class AirflowUtils {

    private static Logger logger = LoggerFactory.getLogger(AirflowUtils.class);

    /**
     * 功能：Airflow日期转换工具类
     * 输入参数格式: Wed, 25 Mar 2020 02:00:00 GMT
     * 输出参数格式：2020-03-25 02:00:00
     */
    public static String dateFormat(String responseTime) {
        // 初始化月份
        Map<String,String> monthsMap = new HashMap<>();
        monthsMap.put("jan","01");
        monthsMap.put("feb","02");
        monthsMap.put("mar","03");
        monthsMap.put("apr","04");
        m