Skip to content
Romain edited this page Aug 27, 2019 · 3 revisions

Producers

BGP data is retrieved with BGPStream2 (see the bgp/producers/bgpstream2.py file)

Format

All entries are msgpack objects compressed with snappy

Example

ConsumerRecord(topic='ihr_bgp_rrc00_updates', partition=0, offset=434463341, timestamp=1566877500000, timestamp_type=0, key=None, value={
'rec': {'project': 'ris', 'collector': 'rrc00', 'type': 'update', 'dump_time': 1566877500, 'time': 1566877500.0, 'status': 'valid', 'dump_position': 'middle'}, 'elements': [
{'type': 'W', 'time': 1566877500.0, 'peer_asn': 3549, 'peer_address': '208.51.134.248', 'fields': {'prefix': '161.22.55.0/24'}}, {'type': 'W', 'time': 1566877500.0, 'peer_asn': 3549, 'peer_address': '208.51.134.248', 'fields': {'prefix': '161.22.52.0/23'}},
{'type': 'W', 'time': 1566877500.0, 'peer_asn': 3549, 'peer_address': '208.51.134.248', 'fields': {'prefix': '161.22.54.0/24'}}
]}, headers=[], checksum=None, serialized_key_size=-1, serialized_value_size=395, serialized_header_size=-1)

List of topics

  • ihr_bgp_route-views2_ribs
  • ihr_bgp_route-views2_updates
  • ihr_bgp_route-views.linx_ribs
  • ihr_bgp_route-views.linx_updates
  • ihr_bgp_rrc00_ribs
  • ihr_bgp_rrc00_updates
  • ihr_bgp_rrc10_ribs
  • ihr_bgp_rrc10_updates

Clone this wiki locally