Struct aws_sdk_rekognition::client::fluent_builders::CreateStreamProcessor

pub struct CreateStreamProcessor<C = DynConnector, M = DefaultMiddleware, R = Standard> { /* private fields */ }

Fluent builder constructing a request to CreateStreamProcessor.

Creates an Amazon Rekognition stream processor that you can use to detect and recognize faces in a streaming video.

Amazon Rekognition Video is a consumer of live video from Amazon Kinesis Video Streams. Amazon Rekognition Video sends analysis results to Amazon Kinesis Data Streams.

You provide as input a Kinesis video stream (Input) and a Kinesis data stream (Output) stream. You also specify the face recognition criteria in Settings. For example, the collection containing faces that you want to recognize. Use Name to assign an identifier for the stream processor. You use Name to manage the stream processor. For example, you can start processing the source video by calling StartStreamProcessor with the Name field.

After you have finished analyzing a streaming video, use StopStreamProcessor to stop processing. You can delete the stream processor by calling DeleteStreamProcessor.

This operation requires permissions to perform the rekognition:CreateStreamProcessor action. If you want to tag your stream processor, you also require permission to perform the rekognition:TagResource operation.

Implementations

impl<C, M, R> CreateStreamProcessor<C, M, R> where
    C: SmithyConnector,
    M: SmithyMiddleware<C>,
    R: NewRequestPolicy, 

pub async fn send(
    self
) -> Result<CreateStreamProcessorOutput, SdkError<CreateStreamProcessorError>> where
    R::Policy: SmithyRetryPolicy<CreateStreamProcessorInputOperationOutputAlias, CreateStreamProcessorOutput, CreateStreamProcessorError, CreateStreamProcessorInputOperationRetryAlias>, 

Sends the request and returns the response.

If an error occurs, an SdkError will be returned with additional details that can be matched against.

By default, any retryable failures will be retried twice. Retry behavior is configurable with the RetryConfig, which can be set when configuring the client.

pub fn input(self, input: StreamProcessorInput) -> Self

Kinesis video stream stream that provides the source streaming video. If you are using the AWS CLI, the parameter name is StreamProcessorInput.

pub fn set_input(self, input: Option<StreamProcessorInput>) -> Self

Kinesis video stream stream that provides the source streaming video. If you are using the AWS CLI, the parameter name is StreamProcessorInput.

pub fn output(self, input: StreamProcessorOutput) -> Self

Kinesis data stream stream to which Amazon Rekognition Video puts the analysis results. If you are using the AWS CLI, the parameter name is StreamProcessorOutput.

pub fn set_output(self, input: Option<StreamProcessorOutput>) -> Self

Kinesis data stream stream to which Amazon Rekognition Video puts the analysis results. If you are using the AWS CLI, the parameter name is StreamProcessorOutput.

pub fn name(self, input: impl Into<String>) -> Self

An identifier you assign to the stream processor. You can use Name to manage the stream processor. For example, you can get the current status of the stream processor by calling DescribeStreamProcessor. Name is idempotent.

pub fn set_name(self, input: Option<String>) -> Self

An identifier you assign to the stream processor. You can use Name to manage the stream processor. For example, you can get the current status of the stream processor by calling DescribeStreamProcessor. Name is idempotent.

pub fn settings(self, input: StreamProcessorSettings) -> Self

Face recognition input parameters to be used by the stream processor. Includes the collection to use for face recognition and the face attributes to detect.

pub fn set_settings(self, input: Option<StreamProcessorSettings>) -> Self

Face recognition input parameters to be used by the stream processor. Includes the collection to use for face recognition and the face attributes to detect.

pub fn role_arn(self, input: impl Into<String>) -> Self

ARN of the IAM role that allows access to the stream processor.

pub fn set_role_arn(self, input: Option<String>) -> Self

ARN of the IAM role that allows access to the stream processor.

pub fn tags(self, k: impl Into<String>, v: impl Into<String>) -> Self

Adds a key-value pair to Tags.

To override the contents of this collection use set_tags.

A set of tags (key-value pairs) that you want to attach to the stream processor.

pub fn set_tags(self, input: Option<HashMap<String, String>>) -> Self

A set of tags (key-value pairs) that you want to attach to the stream processor.

Trait Implementations

impl<C: Clone, M: Clone, R: Clone> Clone for CreateStreamProcessor<C, M, R>

fn clone(&self) -> CreateStreamProcessor<C, M, R>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<C: Debug, M: Debug, R: Debug> Debug for CreateStreamProcessor<C, M, R>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.