|
|
@ -31,7 +31,6 @@ def crawl():
|
|
|
|
if asn not in last_seen:
|
|
|
|
if asn not in last_seen:
|
|
|
|
last_seen[asn] = ASLastSeen(asn=asn)
|
|
|
|
last_seen[asn] = ASLastSeen(asn=asn)
|
|
|
|
asls = last_seen[asn]
|
|
|
|
asls = last_seen[asn]
|
|
|
|
# print(asn, node)
|
|
|
|
|
|
|
|
asls.online = node['online']
|
|
|
|
asls.online = node['online']
|
|
|
|
if node['online']:
|
|
|
|
if node['online']:
|
|
|
|
asls.directlyCrawled = node['directly_crawled']
|
|
|
|
asls.directlyCrawled = node['directly_crawled']
|
|
|
@ -107,7 +106,6 @@ def get_current_network():
|
|
|
|
net.nodes[asls.asn]['online'] = False
|
|
|
|
net.nodes[asls.asn]['online'] = False
|
|
|
|
|
|
|
|
|
|
|
|
log.info("Crawl done in %.2fs", time.time() - crawl_start)
|
|
|
|
log.info("Crawl done in %.2fs", time.time() - crawl_start)
|
|
|
|
print("{} nodes, {} edges".format(len(net.nodes), len(net.edges)))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# add id to edges
|
|
|
|
# add id to edges
|
|
|
|
for n, (_, _, data) in enumerate(net.edges(data=True)):
|
|
|
|
for n, (_, _, data) in enumerate(net.edges(data=True)):
|
|
|
@ -188,5 +186,3 @@ def convert_crawl(crawl):
|
|
|
|
path = list(map(int, ann.ASPath.split()))
|
|
|
|
path = list(map(int, ann.ASPath.split()))
|
|
|
|
net.nodes[asn.number]['routing_table'].add((prefix, tuple(path)))
|
|
|
|
net.nodes[asn.number]['routing_table'].add((prefix, tuple(path)))
|
|
|
|
net.nodes[path[-1]]['prefixes'].add(prefix)
|
|
|
|
net.nodes[path[-1]]['prefixes'].add(prefix)
|
|
|
|
|
|
|
|
|
|
|
|
print(net_to_json(net))
|
|
|
|
|
|
|
|