Describes a stream’s edge configuration that was set using the StartEdgeConfigurationUpdate API and the latest status of the edge agent's recorder and uploader jobs. Use this API to get the status of the configuration to determine if the configuration is in sync with the Edge Agent. Use this API to evaluate the health of the Edge Agent.
Parameters:
-
stream_name
(Optional[StreamName], default:
None
)
–
The name of the stream whose edge configuration you want to update. Specify either the StreamName or the StreamARN.
-
stream_arn
(Optional[ResourceARN], default:
None
)
–
The Amazon Resource Name (ARN) of the stream. Specify either the StreamNameor the StreamARN.
Raises:
Source code in docs_src/capo_kinesis_video/_services/async_kinesis_video.py
| async def describe_edge_configuration(
self,
*,
config_overrides: Optional[AsyncKinesisVideoClientConfig] = None,
stream_name: Optional["capo_kinesis_video.types.stream_name.StreamName"] = None,
stream_arn: Optional[
"capo_kinesis_video.types.resource_arn.ResourceARN"
] = None,
) -> "capo_kinesis_video.types.describe_edge_configuration_output.DescribeEdgeConfigurationOutput":
"""<p>Describes a stream’s edge configuration that was set using the <code>StartEdgeConfigurationUpdate</code> API and the latest status of the edge agent's recorder and uploader jobs. Use this API to get the status of the configuration to determine if the configuration is in sync with the Edge Agent. Use this API to evaluate the health of the Edge Agent.</p>
Args:
stream_name: <p>The name of the stream whose edge configuration you want to update. Specify either the <code>StreamName</code> or the <code>StreamARN</code>. </p>
stream_arn: <p>The Amazon Resource Name (ARN) of the stream. Specify either the <code>StreamName</code>or the <code>StreamARN</code>.</p>
Raises:
capo_kinesis_video.errors.access_denied_exception.AccessDeniedException: <p>You do not have required permissions to perform this operation.</p>
capo_kinesis_video.errors.client_limit_exceeded_exception.ClientLimitExceededException: <p>Kinesis Video Streams has throttled the request because you have exceeded the limit of allowed client calls. Try making the call later.</p>
capo_kinesis_video.errors.invalid_argument_exception.InvalidArgumentException: <p>The value for this input parameter is invalid.</p>
capo_kinesis_video.errors.resource_not_found_exception.ResourceNotFoundException: <p>Amazon Kinesis Video Streams can't find the stream that you specified.</p>
capo_kinesis_video.errors.stream_edge_configuration_not_found_exception.StreamEdgeConfigurationNotFoundException: <p>The Exception rendered when the Amazon Kinesis Video Stream can't find a stream's edge configuration that you specified. </p>
capo_kinesis_video.errors.UnknownServiceError: The service returned an error code this client does not model.
"""
async def _handler(
req: "AsyncOperationRequest[capo_kinesis_video.types.describe_edge_configuration_input.DescribeEdgeConfigurationInput]",
) -> AsyncOperationResponse[
"capo_kinesis_video.types.describe_edge_configuration_output.DescribeEdgeConfigurationOutput"
]:
import capo_kinesis_video._operations.kinesis_video_20170930.describe_edge_configuration
(
output,
http_response,
) = await capo_kinesis_video._operations.kinesis_video_20170930.describe_edge_configuration.async_describe_edge_configuration(
req.options, req.input
)
return AsyncOperationResponse(output=output, response=http_response)
def _redact_output(
output: "capo_kinesis_video.types.describe_edge_configuration_output.DescribeEdgeConfigurationOutput",
) -> dict[str, Any]:
import capo_kinesis_video.types.describe_edge_configuration_output
return capo_kinesis_video.types.describe_edge_configuration_output.redact_sensitive(
output
)
interceptors_, options_ = self.operation_options(
config_overrides,
OperationLogging("DescribeEdgeConfiguration", redact_output=_redact_output),
)
input_: capo_kinesis_video.types.describe_edge_configuration_input.DescribeEdgeConfigurationInput = {}
if stream_name is not None:
input_["stream_name"] = stream_name
if stream_arn is not None:
input_["stream_arn"] = stream_arn
response = await aexecute_pipeline(
AsyncOperationRequest(input=input_, options=options_),
handler=_handler,
interceptors=list(interceptors_),
)
await response.response.aclose()
return response.output
|