ris-live-rs
Provides parsing functions for RIS-Live real-time BGP message stream JSON data.
The main parsing function, parse_ris_live_message converts a JSON-formatted message string into a vector of BgpElems.
Example
use serde_json::json;
use tungstenite::{connect, Message};
use url::Url;
use ris_live_rs::error::ParserRisliveError;
use ris_live_rs::parse_ris_live_message;
const RIS_LIVE_URL: &str = "ws://ris-live.ripe.net/v1/ws/?client=rust-bgpkit-parser";
/// This is an example of subscribing to RIS-Live's streaming data.
///
/// For more RIS-Live details, check out their documentation at https://ris-live.ripe.net/manual/
fn main() {
// connect to RIPE RIS Live websocket server
let (mut socket, _response) =
connect(Url::parse(RIS_LIVE_URL).unwrap())
.expect("Can't connect to RIS Live websocket server");
// subscribe to messages from one collector
let msg = json!({"type": "ris_subscribe", "data": null}).to_string();
socket.write_message(Message::Text(msg)).unwrap();
loop {
let msg = socket.read_message().expect("Error reading message").to_string();
if msg.is_empty() {
continue
}
match parse_ris_live_message(msg.as_str()) {
Ok(elems) => {
for e in elems {
println!("{}", e);
}
}
Err(error) => {
if let ParserRisliveError::ElemEndOfRibPrefix = error {
println!("{:?}", &error);
println!("{}", msg);
continue
}
break;
}
}
}
}
Filtering
ris-live-rs support filtering message by composing customized ris-live subscription message. Use the compose_subscription_message function to create a filtering message.
pub fn compose_subscription_message(
host: Option<String>,
msg_type: Option<String>,
require: Option<String>,
peer: Option<String>,
prefix: Option<String>,
path: Option<String>,
more_specific: bool,
less_specific: bool,
) -> String {
...
}
// subscribe to messages from one collector
let msg = compose_subscription_message(
opts.host,
opts.msg_type,
opts.require,
opts.peer,
opts.prefix,
opts.path,
opts.more_specific,
opts.less_specific
);
println!("{}", &msg);
socket.write_message(Message::Text(msg)).unwrap();
ris-live-reader
ris-live-rs library also comes with a simple command-line program that supports filtering and different output formats: ris-live-reader.
Full command-line options are:
ris-live-rs 0.1.0
Mingwei Zhang <[email protected]>
ris-live-reader is a simple cli tool that can stream BGP data from RIS-Live project with websocket
USAGE:
ris-live-reader [OPTIONS]
OPTIONS:
--client <CLIENT> client name to identify the stream [default: ris-live-rs]
-h, --help Print help information
--host <HOST> Filter by RRC host: e.g. rrc01
--json Output as JSON objects
--less-specific Match prefixes that are less specific (contain) `prefix`
--more-specific Match prefixes that are more specific (part of) `prefix`
--msg-type <MSG_TYPE> Only include messages of a given BGP or RIS type: UPDATE, OPEN,
NOTIFICATION, KEEPALIVE, or RIS_PEER_STATE
--path <PATH> ASN or pattern to match against the AS PATH attribute
--peer <PEER> Only include messages sent by the given BGP peer
--prefix <PREFIX> Filter UPDATE messages by prefixes in announcements or withdrawals
--pretty Pretty-print JSON output
--raw Print out raw message without parsing
--require <REQUIRE> Only include messages containing a given key
-V, --version Print version information
Installation
Install via cargo by:
cargo install ris-live-rs
Or checkout the repo and run:
cargo install --path .
The program ris-live-reader will be installed to your $CARGO_HOME/bin (e.g. ~/.cargo/bin).
Built with
❤️
by BGPKIT Team
BGPKIT is a small-team start-up that focus on building the best tooling for BGP data in Rust. We have 10 years of experience working with BGP data and believe that our work can enable more companies to start keeping tracks of BGP data on their own turf. Learn more about what services we provide at https://bgpkit.com.
44 Oct 9, 2022
2 Aug 20, 2022
72 Jan 1, 2023
448 Jan 2, 2023
11 May 9, 2022
4 Feb 19, 2023
86 Dec 23, 2022
2 Dec 17, 2022
2 Feb 25, 2022
1 Feb 24, 2022
5 Jan 8, 2023
23 May 30, 2023
21.1k Jan 4, 2023
3 Jun 3, 2022
5 Dec 20, 2022
69 Dec 30, 2022
44 Dec 30, 2022
5 Dec 11, 2022
2 Jul 6, 2022