增加设备指纹拉链拦截器

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

@@ -45,4 +45,17 @@ public class InterceptorDataFormatUtil {
 		return arrayList;
 		return arrayList;
 	}
 	}
 
 
+
+	public static List<String> zipperDeviceFingerprintDataFormat(JSONObject jsonObj) {
+		List<String> arrayList = new ArrayList<>();
+		arrayList.add(jsonObj.getString("brand"));
+		arrayList.add(jsonObj.getString("board"));
+		arrayList.add(jsonObj.getString("device_fingerprint"));
+		arrayList.add(jsonObj.getString("device_id"));
+		arrayList.add(jsonObj.getString("uid"));
+		arrayList.add(jsonObj.getString("message"));
+		arrayList.add(jsonObj.getString("status"));
+		return arrayList;
+	}
+	
 }
 }

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

@@ -21,6 +21,8 @@ public class InterceptorSelector {
 			return dataSplit(InterceptorDataFormatUtil.zipperStrategyDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.zipperStrategyDataFormat(jsonObj));
 		}else if(StringUtils.equals(flume_type, "collectLog")) {
 		}else if(StringUtils.equals(flume_type, "collectLog")) {
 			return dataSplit(InterceptorDataFormatUtil.collectLogDataFormat(jsonObj));
 			return dataSplit(InterceptorDataFormatUtil.collectLogDataFormat(jsonObj));
+		}else if(StringUtils.equals(flume_type, "zipperDeviceFingerprint")) {
+			return dataSplit(InterceptorDataFormatUtil.zipperDeviceFingerprintDataFormat(jsonObj));
 		}
 		}
 		return resultStr;
 		return resultStr;
 	}
 	}