10 个版本

0.1.11 2024 年 8 月 17 日
0.1.10 2024 年 6 月 13 日
0.1.9 2024 年 5 月 21 日
0.1.8 2024 年 4 月 2 日
0.1.6 2024 年 3 月 30 日

34#mark-down

Download history 136/week @ 2024-05-20 8/week @ 2024-05-27 141/week @ 2024-06-10 60/week @ 2024-07-01 26/week @ 2024-07-29 128/week @ 2024-08-12

每月 154 次下载

MulanPSL-2.0

18KB
305

s3_put

backblaze 必须使用 "应用程序密钥" 而不是 "主密钥",否则会报错 "Malformed Access Key Id",请参阅 GitHub issue

#![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
}

关于

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

关于

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

依赖

~29MB
~470K SLoC