Wie man einen Befehl in einem Docker Container ausführt in Rust

                          
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
35
36
37
38

                        // Required crate: bollard, futures_util, tokio
// Full tokio runtime should be enabled in Cargo.toml
use bollard::container::LogOutput;
use bollard::Docker;
use bollard::errors::Error;
use bollard::exec::{CreateExecOptions, CreateExecResults, StartExecOptions, StartExecResults};
use futures_util::StreamExt;

#[tokio::main]
async fn main() -> Result<(), Error> {
    let docker = Docker::connect_with_unix_defaults().unwrap();

    let exec_options = CreateExecOptions {
        attach_stdout: Some(true),
        cmd: Some(vec!["echo", "hello world"]),
        ..Default::default()
    };
    let exec_create_response: CreateExecResults = docker.create_exec("container_name", exec_options).await?;
    let exec_id = exec_create_response.id;

    let start_options = StartExecOptions {
        detach: false,
        ..Default::default()
    };
    let mut exec_stream = docker.start_exec(&exec_id, Some(start_options)).await?;

    if let StartExecResults::Attached { mut output, .. } = exec_stream {
        while let Some(msg) = output.next().await {
            if let Ok(LogOutput::StdOut { message }) = msg {
                // Convert to String and remove the newline character at the end.
                let output_str = String::from_utf8_lossy(&message).trim_end().to_string();
                println!("{}", output_str);
            }
        }
    }

    Ok(())
}