dukascopy-rs

直接从 Dukascopy 流式传输历史分时数据

use dukascopy_rs::DukascopyService;
use futures::TryStreamExt;
use time::macros::datetime;

#[tokio::main]
async fn main() {
    DukascopyService::default()
        .download_ticks(
            String::from("EURGBP"),
            // only full hours are supported for now
            datetime!(2020-03-12 13:00),
            datetime!(2020-03-12 15:00),
        )
        .try_for_each(|e| async move {
            println!("{}", e);
            Ok(())
        })
        .await
        .unwrap_or(());
}

来源：example/main.rs

有关可能的输入/输出的详细信息，请参阅 download_ticks 方法文档。

可选的 cargo 功能

• serde - 为 Tick 结构启用序列化支持

待办事项

• 支持任何日期和时间（而不仅仅是完整的小时）
• DataSupplier 在失败时重试请求