10 releases

0.1.11 Aug 17, 2024
0.1.10 Jun 13, 2024
0.1.9 May 21, 2024
0.1.8 Apr 2, 2024
0.1.6 Mar 30, 2024

#16 in #mark-down

Download history 60/week @ 2024-06-29 25/week @ 2024-07-27 1/week @ 2024-08-03 140/week @ 2024-08-17 1/week @ 2024-08-24 10/week @ 2024-09-14 24/week @ 2024-09-21 22/week @ 2024-09-28

56 downloads per month

MulanPSL-2.0

18KB
305 lines

s3_put

backblaze 必须用 " 应用程序密钥 " 而不是 " 主密钥 ", 不然会报错 "Malformed Access Key Id"

#![feature(async_closure)]
#![feature(let_chains)]

use std::sync::Arc;

use aok::{Result, OK};
use map_await::{MapAwait, StreamExt};
use s3_put::S3Bucket;
use static_init::constructor;
use tracing::info;
use walkdir::WalkDir;

#[constructor(0)]
extern "C" fn init() {
  loginit::init()
}

#[tokio::test]
async fn test() -> Result<()> {
  let dir = env!("CARGO_MANIFEST_DIR");
  let toml = format!("{dir}/Cargo.toml");
  info!("{}", toml);
  let s3 = Arc::new(S3Bucket::from_env("i18ntmp"));
  let mut iter = WalkDir::new(dir).map_unordered(3, move |i| {
    let s3 = s3.clone();
    async move {
      if let Ok::<walkdir::DirEntry, _>(i) = i {
        let file_type = i.file_type();
        if file_type.is_file() {
          let path = i.path();

          if let Some(url) = path.strip_prefix(dir)?.as_os_str().to_str() {
            info!("begin upload {url}");
            s3.put(url, "text/js", path).await?;
            info!("uploaded {url}");
          }
        }
      }
      OK
    }
  });
  while let Some(r) = iter.next().await {
    r?;
  }
  OK
}

About

This project is an open-source component of i18n.site ⋅ Internationalization Solution.

关于

本项目为 i18n.site ⋅ 国际化解决方案 的开源组件。

Dependencies

~33MB
~440K SLoC