create_input async ¶

async def create_input(
    self,
    *,
    config_overrides: Optional[AsyncMediaLiveClientConfig] = None,
    destinations: Optional[
        "capo_medialive.types.__list_of_input_destination_request.__listOfInputDestinationRequest"
    ] = None,
    input_devices: Optional[
        "capo_medialive.types.__list_of_input_device_settings.__listOfInputDeviceSettings"
    ] = None,
    input_security_groups: Optional[
        "capo_medialive.types.__list_of__string.__listOf__string"
    ] = None,
    media_connect_flows: Optional[
        "capo_medialive.types.__list_of_media_connect_flow_request.__listOfMediaConnectFlowRequest"
    ] = None,
    name: Optional["capo_medialive.types.__string.__string"] = None,
    request_id: Optional["capo_medialive.types.__string.__string"] = None,
    role_arn: Optional["capo_medialive.types.__string.__string"] = None,
    sources: Optional[
        "capo_medialive.types.__list_of_input_source_request.__listOfInputSourceRequest"
    ] = None,
    tags: Optional["capo_medialive.types.tags.Tags"] = None,
    type: Optional["capo_medialive.types.input_type.InputType"] = None,
    vpc: Optional["capo_medialive.types.input_vpc_request.InputVpcRequest"] = None,
    srt_settings: Optional[
        "capo_medialive.types.srt_settings_request.SrtSettingsRequest"
    ] = None,
    input_network_location: Optional[
        "capo_medialive.types.input_network_location.InputNetworkLocation"
    ] = None,
    multicast_settings: Optional[
        "capo_medialive.types.multicast_settings_create_request.MulticastSettingsCreateRequest"
    ] = None,
    smpte2110_receiver_group_settings: Optional[
        "capo_medialive.types.smpte2110_receiver_group_settings.Smpte2110ReceiverGroupSettings"
    ] = None,
    sdi_sources: Optional[
        "capo_medialive.types.input_sdi_sources.InputSdiSources"
    ] = None,
    router_settings: Optional[
        "capo_medialive.types.router_settings.RouterSettings"
    ] = None,
) -> "capo_medialive.types.create_input_response.CreateInputResponse":
    """Create an input

    Args:
        destinations: Destination settings for PUSH type inputs.
        input_devices: Settings for the devices.
        input_security_groups: A list of security groups referenced by IDs to attach to the input.
        media_connect_flows: A list of the MediaConnect Flows that you want to use in this input. You can specify as few as one Flow and presently, as many as two. The only requirement is when you have more than one is that each Flow is in a separate Availability Zone as this ensures your EML input is redundant to AZ issues.
        name: Name of the input.
        request_id: Unique identifier of the request to ensure the request is handled exactly once in case of retries.
        role_arn: The Amazon Resource Name (ARN) of the role this input assumes during and after creation.
        sources: The source URLs for a PULL-type input. Every PULL type input needs exactly two source URLs for redundancy. Only specify sources for PULL type Inputs. Leave Destinations empty.
        tags: A collection of key-value pairs.
        srt_settings: The settings associated with an SRT input.
        input_network_location: The location of this input. AWS, for an input existing in the AWS Cloud, On-Prem for an input in a customer network.
        multicast_settings: Multicast Input settings.
        smpte2110_receiver_group_settings: Include this parameter if the input is a SMPTE 2110 input, to identify the stream sources for this input.

    Raises:
        capo_medialive.errors.bad_gateway_exception.BadGatewayException: Placeholder documentation for BadGatewayException
        capo_medialive.errors.bad_request_exception.BadRequestException: Placeholder documentation for BadRequestException
        capo_medialive.errors.forbidden_exception.ForbiddenException: Placeholder documentation for ForbiddenException
        capo_medialive.errors.gateway_timeout_exception.GatewayTimeoutException: Placeholder documentation for GatewayTimeoutException
        capo_medialive.errors.internal_server_error_exception.InternalServerErrorException: Placeholder documentation for InternalServerErrorException
        capo_medialive.errors.too_many_requests_exception.TooManyRequestsException: Placeholder documentation for TooManyRequestsException
        capo_medialive.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_medialive.types.create_input_request.CreateInputRequest]",
    ) -> AsyncOperationResponse[
        "capo_medialive.types.create_input_response.CreateInputResponse"
    ]:
        import capo_medialive._operations.media_live.create_input

        (
            output,
            http_response,
        ) = await capo_medialive._operations.media_live.create_input.async_create_input(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("CreateInput")
    )
    input_: capo_medialive.types.create_input_request.CreateInputRequest = {}
    if destinations is not None:
        input_["destinations"] = destinations
    if input_devices is not None:
        input_["input_devices"] = input_devices
    if input_security_groups is not None:
        input_["input_security_groups"] = input_security_groups
    if media_connect_flows is not None:
        input_["media_connect_flows"] = media_connect_flows
    if name is not None:
        input_["name"] = name
    if request_id is None:
        request_id = str(uuid.uuid4())
    input_["request_id"] = request_id
    if role_arn is not None:
        input_["role_arn"] = role_arn
    if sources is not None:
        input_["sources"] = sources
    if tags is not None:
        input_["tags"] = tags
    if type is not None:
        input_["type"] = type
    if vpc is not None:
        input_["vpc"] = vpc
    if srt_settings is not None:
        input_["srt_settings"] = srt_settings
    if input_network_location is not None:
        input_["input_network_location"] = input_network_location
    if multicast_settings is not None:
        input_["multicast_settings"] = multicast_settings
    if smpte2110_receiver_group_settings is not None:
        input_["smpte2110_receiver_group_settings"] = (
            smpte2110_receiver_group_settings
        )
    if sdi_sources is not None:
        input_["sdi_sources"] = sdi_sources
    if router_settings is not None:
        input_["router_settings"] = router_settings

    response = await aexecute_pipeline(
        AsyncOperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    await response.response.aclose()
    return response.output