gfwleak/wanglihui-ip-learning-graph
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

R_LOCATE_FQDN2IP增加字段 FQDN，IP

Browse Source
This commit is contained in:
zhanghongqing
2022-09-20 18:14:48 +08:00
parent e4260517fc
commit 110ad435f1
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
ip-learning-spark/src/main/scala/cn/ac/iie/service/update/UpdateDocument.scala
View File

@@ -144,8 +144,10 @@ object UpdateDocument {
val key = subId.concat("-" + ip + "-" + vsysId) val key = subId.concat("-" + ip + "-" + vsysId)
if (subidLocIpDoc != null) { if (subidLocIpDoc != null) {
updateMaxAttribute(subidLocIpDoc, lastFoundTime, "LAST_FOUND_TIME")
subidLocIpDoc.addAttribute("VSYS_ID", vsysId) subidLocIpDoc.addAttribute("VSYS_ID", vsysId)
subidLocIpDoc.addAttribute("SUBSCRIBER", subId)
subidLocIpDoc.addAttribute("IP", ip)
updateMaxAttribute(subidLocIpDoc, lastFoundTime, "LAST_FOUND_TIME")
} else { } else {
subidLocIpDoc = new BaseEdgeDocument() subidLocIpDoc = new BaseEdgeDocument()
subidLocIpDoc.setKey(key) subidLocIpDoc.setKey(key)
@@ -286,17 +288,20 @@ object UpdateDocument {
val distinctIp: Array[String] = mergeDistinctIp(distCipRecent) val distinctIp: Array[String] = mergeDistinctIp(distCipRecent)
val key = fqdn.concat("-" + serverIp + "-" + vsysId) val key = fqdn.concat("-" + serverIp + "-" + vsysId)
if (fqdnLocIpDoc != null) { if (fqdnLocIpDoc != null) {
fqdnLocIpDoc.addAttribute("FQDN", fqdn)
fqdnLocIpDoc.addAttribute("IP", serverIp)
fqdnLocIpDoc.addAttribute("VSYS_ID", vsysId)
updateMaxAttribute(fqdnLocIpDoc, lastFoundTime, "LAST_FOUND_TIME") updateMaxAttribute(fqdnLocIpDoc, lastFoundTime, "LAST_FOUND_TIME")
updateProtocolAttritube(fqdnLocIpDoc, sepAttritubeMap) updateProtocolAttritube(fqdnLocIpDoc, sepAttritubeMap)
updateDistinctIp(fqdnLocIpDoc, distinctIp) updateDistinctIp(fqdnLocIpDoc, distinctIp)
fqdnLocIpDoc.addAttribute("VSYS_ID", vsysId)
} else { } else {
fqdnLocIpDoc = new BaseEdgeDocument() fqdnLocIpDoc = new BaseEdgeDocument()
fqdnLocIpDoc.setKey(key) fqdnLocIpDoc.setKey(key)
fqdnLocIpDoc.setFrom("FQDN/" + fqdn+ "-" + vsysId) fqdnLocIpDoc.setFrom("FQDN/" + fqdn+ "-" + vsysId)
fqdnLocIpDoc.setTo("IP/" + serverIp+ "-" + vsysId) fqdnLocIpDoc.setTo("IP/" + serverIp+ "-" + vsysId)
fqdnLocIpDoc.addAttribute("FIRST_FOUND_TIME", firstFoundTime) fqdnLocIpDoc.addAttribute("FIRST_FOUND_TIME", firstFoundTime)
fqdnLocIpDoc.addAttribute("LAST_FOUND_TIME", lastFoundTime) fqdnLocIpDoc.addAttribute("FQDN", fqdn)
fqdnLocIpDoc.addAttribute("IP", serverIp)
fqdnLocIpDoc.addAttribute("VSYS_ID", vsysId) fqdnLocIpDoc.addAttribute("VSYS_ID", vsysId)
putProtocolAttritube(fqdnLocIpDoc, sepAttritubeMap) putProtocolAttritube(fqdnLocIpDoc, sepAttritubeMap)