Function dataflow::source::s3::process_message [−][src]
async fn process_message(
message: SqsMessage,
glob: Option<&GlobMatcher>,
base_metrics: SourceBaseMetrics,
metrics: &mut HashMap<String, ScanBucketMetrics>,
source_id: &str,
tx: &Sender<Result<KeyInfo, S3Error>>,
client: &SqsClient,
queue_url: &str
) -> Option<(SqsMessage, String)>
Expand description
Send the relevant parts of the message to the download objects task
Returns any message that wasn’t able to be processed to be released back to the SQS service, as well as the specific key that we failed to process from that message.