extern crate amtrak_gtfs_rt;

use prost::Message;
use gtfs_structures::Gtfs;

#[tokio::main]
async fn main() {
    let gtfs = Gtfs::from_url_async("https://content.amtrak.com/content/gtfs/GTFS.zip")
    .await
    .unwrap();

    let client = reqwest::Client::new();
    loop {
        let amtrak_gtfs_rt = amtrak_gtfs_rt::fetch_amtrak_gtfs_rt(&gtfs, &client).await.unwrap();

        //extract the binary data
        let vehicle_data = amtrak_gtfs_rt.vehicle_positions.encode_to_vec();
        let trip_data = amtrak_gtfs_rt.trip_updates.encode_to_vec();

        std::thread::sleep(std::time::Duration::from_millis(500));
    }
}

此软件包解密 Amtrak track-a-train json 数据，并在 GTFS 调度中进行行程信息查找，以将每辆车与它的 route_id 和 trip_id 匹配。

欢迎 Pull requests！

Capital Corridor 异常

请注意，大都市交通委员会还在其自己的源中发布 Capital Corridor。 https://511.org/open-data/transit 将 Capital Corridor 作为 "CC" 提供。此数据更新得更频繁（且位置和时间更接近），并显示机车编号。因此，您可能希望从该源中删除 Capital Corridor。因此，我们包含了一个函数 filter_capital_corridor()，该函数接受任何 gtfs_rt::FeedMessage 并删除 CC 车辆和行程。