pc采集拦截器

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

@@ -275,4 +275,40 @@ public class InterceptorDataFormatUtil {
 		return arrayList;
 		return arrayList;
 	}
 	}
 
 
+	public static List<String> pcCollectLogDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("id"));
+		arrayList.add(jsonObj.getString("app_key"));
+		arrayList.add(jsonObj.getString("app_version"));
+		arrayList.add(jsonObj.getString("app_type"));
+		arrayList.add(jsonObj.getString("app_channel"));
+		arrayList.add(jsonObj.getString("send_time"));
+		arrayList.add(jsonObj.getString("send_type"));
+		arrayList.add(jsonObj.getString("zone_code"));
+		arrayList.add(jsonObj.getString("zone_name"));
+		arrayList.add(jsonObj.getString("zone_type"));
+		arrayList.add(jsonObj.getString("device_info"));
+		arrayList.add(jsonObj.getString("user_agent"));
+		arrayList.add(jsonObj.getString("create_time"));
+		return arrayList;
+	}
+
+	public static List<String> pcEventLogDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("id"));
+		arrayList.add(jsonObj.getString("app_key"));
+		arrayList.add(jsonObj.getString("app_version"));
+		arrayList.add(jsonObj.getString("app_type"));
+		arrayList.add(jsonObj.getString("app_channel"));
+		arrayList.add(jsonObj.getString("send_time"));
+		arrayList.add(jsonObj.getString("send_type"));
+		arrayList.add(jsonObj.getString("zone_code"));
+		arrayList.add(jsonObj.getString("zone_name"));
+		arrayList.add(jsonObj.getString("zone_type"));
+		arrayList.add(jsonObj.getString("event_info"));
+		arrayList.add(jsonObj.getString("user_agent"));
+		arrayList.add(jsonObj.getString("create_time"));
+		return arrayList;
+	}
+
 }
 }

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

@@ -55,6 +55,10 @@ public class InterceptorSelector {
 			return dataSplit(InterceptorDataFormatUtil.eventIpConvertDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.eventIpConvertDataFormat(jsonObj));
 		}else if(StringUtils.equals(flume_type, "openApi")) {
 		}else if(StringUtils.equals(flume_type, "openApi")) {
 			return dataSplit(InterceptorDataFormatUtil.openApiDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.openApiDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "pcCollectLog")) {
+			return dataSplit(InterceptorDataFormatUtil.pcCollectLogDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "pcEventLog")) {
+			return dataSplit(InterceptorDataFormatUtil.pcEventLogDataFormat(jsonObj));
 		}
 		}
 		return resultStr;
 		return resultStr;
 	}
 	}