Skip to content

Latest commit

 

History

History
74 lines (68 loc) · 2.44 KB

README.md

File metadata and controls

74 lines (68 loc) · 2.44 KB
Raw

AS Hegemony

The purpose of this project is to calculate hegemony value for any AS or prefix globally reachable.

produce_bgpatom

  • running script
python3 produce_bgpatom.py -c rrc00 -s 2020-08-01T00:00:00 -e 2020-08-01T01:00:00
python3 produce_bgpatom.py -c rrc10 -s 2020-08-01T00:00:00 -e 2020-08-01T01:00:00
python3 produce_bgpatom.py -c route-views2 -s 2020-08-01T00:00:00 -e 2020-08-01T01:00:00
python3 produce_bgpatom.py -c route-views.linx -s 2020-08-01T00:00:00 -e 2020-08-01T01:00:00
  • produce compressed bgp data, message format
{
    "prefixes": "a batch of tuple (prefix, origin_as)",
    "aspath": "as_path",
    "peer_address": "address of peer",
    "timestamp": "timestamp"
}

produce_bscore

  • running script for producing AS hegemony score
python3 produce_bcscore.py -c rrc00 -s 2020-08-01T00:00:00 -e 2020-08-01T01:00:00
python3 produce_bcscore.py -c rrc10 -s 2020-08-01T00:00:00 -e 2020-08-01T01:00:00
python3 produce_bcscore.py -c route-views2 -s 2020-08-01T00:00:00 -e 2020-08-01T01:00:00
python3 produce_bcscore.py -c route-views.linx -s 2020-08-01T00:00:00 -e 2020-08-01T01:00:00
  • running script for producing Prefix hegemony score
python3 produce_bcscore.py -p -s 2020-08-01T00:00:00 -e 2020-08-01T00:15:00 -c rrc00
  • produce AS's between-ness centrality score
{
    "bcscore": "bcscore",
    "scope": "asn scope",
    "peer_address": "address of peer",
    "peer_asn": "asn of peer",
    "collector": "collector",
    "timestamp": "timestamp"
}

produce_hege

  • running script for producing AS hegemony score
python3 produce_hege.py -s 2020-08-01T00:00:00 -e 2020-08-01T00:15:00 -c rrc00,rrc10,route-views.linx,route-views2
  • running script for producing Prefix hegemony score
python3 produce_hege.py -p -s 2020-08-01T00:00:00 -e 2020-08-01T00:15:00 -c rrc00,rrc10,route-views.linx,route-views2

hege_loader.py

  • running script to get data from a specific scope
python3 -m hege.hegemony.hege_loader -t 2020-08-01T00:00:00 -s as15169
python3 -m hege.hegemony.hege_loader -t 2020-08-01T00:00:00 -s 8.8.8.8

config.json

{
  "kafka": {
    "bootstrap_servers": "kafka:9092",
    "no_new_message_limit": 60, // consumer wait 1 minute between 2 messages
    "leader_wait_minutes": 60, // consumer wait 1 hour for offset timestamp to be available 
    "default_topic_config": 
  }
}