Описание тега rusoto

Вопросы с тегом
2 ответа

Как передать структуру с параметрами типа в качестве аргумента функции?

Как мне передать экземпляр EcsClient с подписью impl<P, D> EcsClient<P, D> where P: ProvideAwsCredentials, D: DispatchSignedRequest к функции в качестве ссылки в Rust? Моя попытка такова: extern crate rusoto; use std::default::Default; u…
06 фев '17 в 09:56
1 ответ

Как сохранить файл, загруженный с S3 с Rusoto, на мой жесткий диск?

Я пытаюсь загрузить файл из корзины с Rusoto и получаю содержимое файла: fn get_object(client: &TestClient, bucket: &str, filename: &str) { let get_req = GetObjectRequest { bucket: bucket.to_owned(), key: filename.to_owned(), ..Default::…
11 июл '18 в 13:55
1 ответ

Загрузка строки в S3 с помощью rusoto

Я использую rusoto S3 для создания строки JSON и загрузки этой строки в корзину S3. Я могу создать строку, но S3 Русото PutObjectRequest требует StreamingBody и я не уверен, как я могу создать StreamingBody из строки или действительно ли это необход…
16 дек '18 в 02:55
2 ответа

Docker и "Библиотека OpenSSL сообщила об ошибке" при развертывании

Я предоставляю API через Rust и Rocket через сервис Amazon Elastic Container Service. Всякий раз, когда я помещаю или получаю объекты в Amazon S3, он отлично работает локально, но при развертывании в Amazon ECS я получаю эту ошибку времени выполнени…
23 июн '17 в 19:08
0 ответов

Чтение Rusoto S3 StreamingBody в то, что Brotli может распаковать

Версия 0.32 StreamingBody от rusuto_s3, которая возвращается при запросе файла из AWS S3, больше не поддерживает Read. До этой версии, brotli::BrotliDecompress(&mut &*would_like_to_pass_this, &mut contents); был способ, которым я получал…
14 июн '18 в 18:54
0 ответов

Цепочка фьючерсов в Actix с Rusoto

Я пытаюсь отправить сообщение актеру, чтобы вернуть объект, а затем отправить материал на S3, используя rusoto. Код до сих пор: use actix_web::{ actix::{Actor, Addr, Handler, Message, SyncArbiter, SyncContext, System}, server, App, Error, FutureResp…
03 апр '19 в 16:40
1 ответ

Rusoto Async с использованием комбинатора FuturesOrdered

Я пытаюсь отправить параллельные асинхронные запросы Rusoto SQS, используя FuturesOrdered: use futures::prelude::*; // 0.1.26 use futures::stream::futures_unordered::FuturesUnordered; use rusoto_core::{Region, HttpClient}; // 0.38.0 use rusoto_crede…
07 май '19 в 12:06
0 ответов

Nested Future Chain не называет внутреннего будущего для Rusoto RusotoFuture

Я пытаюсь использовать rusoto получить список файлов через ListObjects позвони на это S3 Ящик, однако, когда я приковываю его цепочку к следующему набору фьючерсов, кажется, что внутренние фьючерсы не вызваны, я безуспешно пробовал многие конфигурац…
20 июн '19 в 08:00
1 ответ

Почему чтение из потока Rusoto S3 в веб-обработчике Actix вызывает тупик?

Я пишу приложение, используя actix_web а также rusoto_s3, Когда я запускаю команду вне запроса actix непосредственно из mainработает нормально, а get_object работает как положено. Когда это инкапсулировано в запросе actix_web, поток блокируется навс…
02 июл '19 в 09:25
1 ответ

Как использовать select_object_content через rusoto / rust?

Следующий код пытается выбрать некоторые данные из файла, хранящегося на S3: let client = S3Client::new(Region::default()); let source = ... object providing bucket and key ...; let r = SelectObjectContentRequest { bucket: source.bucket, key: source…
23 авг '19 в 17:32
0 ответов

Как сохранить составное поле actix в s3, используя rusoto_s3?

Я совершенно новый для ржавчины, но учусь. Я пытаюсь выполнить многоэтапную загрузку с помощью actix_web и actix_multipart и загрузить ее в aws s3 с помощью rusoto_s3. Из моего базового понимания в основном у меня есть поток одного типа, который мне…
18 авг '19 в 08:31
2 ответа

Потоковая загрузка в s3 с помощью rusoto

Как с помощью rusoto закачать файл в s3, не читая содержимое файла в память (потоковое)? С этим кодом: use std::fs::File; use std::io::BufReader; use rusoto_core::Region; use rusoto_s3::{PutObjectRequest, S3, S3Client, StreamingBody}; fn main() { le…
05 сен '19 в 20:11
1 ответ

Как я могу вернуться к учетным данным из файла, если переменные среды не найдены?

Как я могу отказаться от использования учетных данных из проанализированного файла (config.yml) если переменные среды не найдены? Для тестирования я использую этот пример: extern crate rusoto_core; extern crate rusoto_s3; use rusoto_core::credential…
02 окт '19 в 13:17
1 ответ

Потоковая загрузка Rusoto с использованием sigv4

У меня проблемы с потоковой загрузкой на S3: // rust version 1.42.0 // OS macos // [dependencies] // rusoto_core = "0.43.0" // rusoto_s3 = "0.43.0" // log = "0.4" // pretty_env_logger = "0.4.0" // tokio = "0.2.14" // tokio-util = { version = "0.3.1"…
08 апр '20 в 18:51
2 ответа

Паника при запуске асинхронного кода при удалении Rust Future

У меня есть приложение, использующее #[tokio::main], который создает несколько ресурсов на AWS в одной из своих задач. Я реализовал очистку этих ресурсов вDropобработчики. Однако эти функции очистки являются асинхронными, поэтому я используюblock_on…
28 янв '20 в 04:05
1 ответ

Как преобразовать futures_io :: AsyncRead в rusoto :: ByteStream?

Я пытаюсь создать службу, которая извлекает файлы с сервера SFTP и загружает их в S3. Для части SFTP я использую async-ssh2, который дает мне обработчик файлов, реализующий futures::AsyncRead . Поскольку эти файлы SFTP могут быть довольно большими, …
09 июн '20 в 22:08
1 ответ

Tokio core.run не компилируется. получена ошибка: трейт `futures::future::Future` не реализован для ʻimpl futures::Future`

Я изучаю Rust и Rusoto с помощью этого примера https://www.rusoto.org/futures.html И я обнаружил, что многие коды устарели. Поэтому я изменил код следующим образом: use rusoto_core::{Region, RusotoError}; use rusoto_dynamodb::{ AttributeDefinition, …
13 июн '20 в 14:32
1 ответ

Как поместить свою структуру в PutRecordInput для AWS Kinesis в Rust?

Я очень новичок в Rust и пытаюсь заставить работать код, который может проталкивать запись в поток kinesis firehose. struct AuditRecord{ user_id : String, request : Value, request_id : String, timestamp_raw : i64, } ... let client = KinesisClient::n…
12 май '20 в 23:20
0 ответов

Почему загрузка файла с S3 с помощью Rusoto иногда возвращает пустую строку?

Пытаюсь получить тело из существующего файла в ведре S3 с помощью русото. Мой body.unwrapвозвращает пустую строку, и я не понимаю почему. У меня нет проблем или ошибок, и мой файл в порядке. Похоже, я иногда получаю пустой контент от S3. Это быстрый…
14 сен '20 в 15:26
1 ответ

Как мне использовать actix-web 3 и rusoto 0.46 вместе?

Когда я пытаюсь использовать actix-web 3 и rusoto 0.46 вместе, я получаю следующую ошибку времени выполнения: thread 'actix-rt:worker:0' panicked at 'there is no reactor running, must be called from the context of a Tokio 1.x runtime', /Users/matt/.…
09 фев '21 в 16:22