Adds media streams to an existing flow. After you add a media stream to a flow, you can associate it with a source and/or an output that uses the ST 2110 JPEG XS or CDI protocol.
Parameters:
Raises:
Source code in docs_src/capo_mediaconnect/_services/async_media_connect.py
| async def add_flow_media_streams(
self,
flow_arn: "capo_mediaconnect.types.flow_arn.FlowArn",
*,
config_overrides: Optional[AsyncMediaConnectClientConfig] = None,
media_streams: Optional[
"capo_mediaconnect.types.__list_of_add_media_stream_request.__listOfAddMediaStreamRequest"
] = None,
) -> "capo_mediaconnect.types.add_flow_media_streams_response.AddFlowMediaStreamsResponse":
"""<p> Adds media streams to an existing flow. After you add a media stream to a flow, you can associate it with a source and/or an output that uses the ST 2110 JPEG XS or CDI protocol.</p>
Args:
flow_arn: <p> The Amazon Resource Name (ARN) of the flow.</p>
media_streams: <p> The media streams that you want to add to the flow.</p>
Raises:
capo_mediaconnect.errors.bad_request_exception.BadRequestException: <p>This exception is thrown if the request contains a semantic error. The precise meaning depends on the API, and is documented in the error message. </p>
capo_mediaconnect.errors.forbidden_exception.ForbiddenException: <p>You do not have sufficient access to perform this action. </p>
capo_mediaconnect.errors.internal_server_error_exception.InternalServerErrorException: <p>The server encountered an internal error and is unable to complete the request. </p>
capo_mediaconnect.errors.not_found_exception.NotFoundException: <p>One or more of the resources in the request does not exist in the system. </p>
capo_mediaconnect.errors.service_unavailable_exception.ServiceUnavailableException: <p>The service is currently unavailable or busy. </p>
capo_mediaconnect.errors.too_many_requests_exception.TooManyRequestsException: <p>The request was denied due to request throttling. </p>
capo_mediaconnect.errors.UnknownServiceError: The service returned an error code this client does not model.
"""
async def _handler(
req: "AsyncOperationRequest[capo_mediaconnect.types.add_flow_media_streams_request.AddFlowMediaStreamsRequest]",
) -> AsyncOperationResponse[
"capo_mediaconnect.types.add_flow_media_streams_response.AddFlowMediaStreamsResponse"
]:
import capo_mediaconnect._operations.media_connect.add_flow_media_streams
(
output,
http_response,
) = await capo_mediaconnect._operations.media_connect.add_flow_media_streams.async_add_flow_media_streams(
req.options, req.input
)
return AsyncOperationResponse(output=output, response=http_response)
interceptors_, options_ = self.operation_options(
config_overrides, OperationLogging("AddFlowMediaStreams")
)
input_: capo_mediaconnect.types.add_flow_media_streams_request.AddFlowMediaStreamsRequest = {
"flow_arn": flow_arn
}
if media_streams is not None:
input_["media_streams"] = media_streams
response = await aexecute_pipeline(
AsyncOperationRequest(input=input_, options=options_),
handler=_handler,
interceptors=list(interceptors_),
)
await response.response.aclose()
return response.output
|