dbcrossbarlib 0.5.3

Library for copying data between databases (pre-release)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

//! Deleting data from S3.

use std::process::Stdio;

use super::aws_s3_command;
use crate::common::*;

/// Recursively delete a `s3://` directory without deleting the bucket.
#[instrument(level = "trace")]
pub(crate) async fn rmdir(url: &Url) -> Result<()> {
    // Delete all the files under `url`.
    debug!("deleting existing {}", url);
    if !url.path().ends_with('/') {
        return Err(format_err!(
            "can only write to s3:// URL ending in '/', got {}",
            url,
        ));
    }
    let status = aws_s3_command()
        .await?
        .args(["rm", "--recursive", url.as_str()])
        // Throw away stdout so it doesn't corrupt our output.
        .stdout(Stdio::null())
        .status()
        .await
        .context("error running `aws s3`")?;
    if !status.success() {
        warn!(
            "can't delete contents of {}, possibly because it doesn't exist",
            url,
        );
    }
    Ok(())
}