事件采集

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

@@ -28,8 +28,33 @@ public class InterceptorDataFormatUtil {
 		arrayList.add(jsonObj.getString("zone_name"));
 		arrayList.add(jsonObj.getString("zone_name"));
 		arrayList.add(jsonObj.getString("zone_type"));
 		arrayList.add(jsonObj.getString("zone_type"));
 		arrayList.add(jsonObj.getString("sdk_version"));
 		arrayList.add(jsonObj.getString("sdk_version"));
-		arrayList.add(jsonObj.getString("collect_log"));
 		arrayList.add(jsonObj.getString("user_agent"));
 		arrayList.add(jsonObj.getString("user_agent"));
+		arrayList.add(jsonObj.getString("other_info"));
+		arrayList.add(jsonObj.getString("device_info"));
+		arrayList.add(jsonObj.getString("env_info"));
+		arrayList.add(jsonObj.getString("user_name"));
+		return arrayList;
+	}
+	
+	public static List<String> eventLogDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("send_time"));
+		arrayList.add(jsonObj.getString("create_time"));
+		arrayList.add(jsonObj.getString("strategy_group_id"));
+		arrayList.add(jsonObj.getString("app_key"));
+		arrayList.add(jsonObj.getString("app_type"));
+		arrayList.add(jsonObj.getString("app_channel"));
+		arrayList.add(jsonObj.getString("zone_code"));
+		arrayList.add(jsonObj.getString("zone_name"));
+		arrayList.add(jsonObj.getString("zone_type"));
+		arrayList.add(jsonObj.getString("sdk_version"));
+		arrayList.add(jsonObj.getString("user_agent"));
+		arrayList.add(jsonObj.getString("device_id"));
+		arrayList.add(jsonObj.getString("uid"));
+		arrayList.add(jsonObj.getString("strategy_version"));
+		arrayList.add(jsonObj.getString("event_list"));
+		arrayList.add(jsonObj.getString("route_ip"));
+		arrayList.add(jsonObj.getString("user_name"));
 		return arrayList;
 		return arrayList;
 	}
 	}
 	
 	

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

@@ -19,10 +19,12 @@ public class InterceptorSelector {
 		String flume_type = jsonObj.getString("flume_type");
 		String flume_type = jsonObj.getString("flume_type");
 		if(StringUtils.equals(flume_type, "zipperStrategy")) {
 		if(StringUtils.equals(flume_type, "zipperStrategy")) {
 			return dataSplit(InterceptorDataFormatUtil.zipperStrategyDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.zipperStrategyDataFormat(jsonObj));
-		}else if(StringUtils.equals(flume_type, "collectLog")) {
-			return dataSplit(InterceptorDataFormatUtil.collectLogDataFormat(jsonObj));
 		}else if(StringUtils.equals(flume_type, "zipperDeviceFingerprint")) {
 		}else if(StringUtils.equals(flume_type, "zipperDeviceFingerprint")) {
 			return dataSplit(InterceptorDataFormatUtil.zipperDeviceFingerprintDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.zipperDeviceFingerprintDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "collectLog")) {
+			return dataSplit(InterceptorDataFormatUtil.collectLogDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "eventLog")) {
+			return dataSplit(InterceptorDataFormatUtil.eventLogDataFormat(jsonObj));
 		}
 		}
 		return resultStr;
 		return resultStr;
 	}
 	}