拦截器增加openAPI

flume-interceptor/src/main/java/com/org/apache/flume/interceptor/TimestampeInterceptor.java

@@ -30,7 +30,7 @@ public class TimestampeInterceptor implements Interceptor{
 	@Override
 	public Event intercept(Event event) {
 		String log = new String(event.getBody(),StandardCharsets.UTF_8);
-		System.out.println("TimestampeInterceptor>>>>>>>>>>>>>>>>>>>>>开始"+log);
+		System.out.println("TimestampeInterceptor>>>>>>>>>>>>>>>>>>>>>开始");
 		JSONObject jsonObj = new JSONObject();
 		try {
 			jsonObj = JSONObject.parseObject(log);

flume-interceptor/src/main/java/com/org/apache/flume/interceptor/interceptor/InterceptorDataFormatUtil.java

@@ -126,5 +126,17 @@ public class InterceptorDataFormatUtil {
 		arrayList.add(jsonObj.getString("forwardType"));
 		return arrayList;
 	}
+
+	public static List<String> openApiDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("req_body"));
+		arrayList.add(jsonObj.getString("res_body"));
+		arrayList.add(jsonObj.getString("date_time"));
+		arrayList.add(jsonObj.getString("send_type"));
+		arrayList.add(jsonObj.getString("zone_code"));
+		arrayList.add(jsonObj.getString("zone_time"));
+		arrayList.add(jsonObj.getString("ua"));
+		return arrayList;
+	}
 	
 }

flume-interceptor/src/main/java/com/org/apache/flume/interceptor/interceptor/InterceptorSelector.java

@@ -31,6 +31,8 @@ public class InterceptorSelector {
 			return dataSplit(InterceptorDataFormatUtil.sminCommunityAiClassDataFormat(jsonObj));
 		}else if(StringUtils.equals(flume_type, "sminCommunityCollect")) {
 			return dataSplit(InterceptorDataFormatUtil.sminCommunityCollectDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "openApi")) {
+			return dataSplit(InterceptorDataFormatUtil.openApiDataFormat(jsonObj));
 		}
 		return resultStr;
 	}