Skip to content

delete_application_input_processing_configuration async 

delete_application_input_processing_configuration(
    application_name: ApplicationName,
    current_application_version_id: ApplicationVersionId,
    input_id: Id,
    *,
    config_overrides: Optional[AsyncKinesisAnalyticsV2ClientConfig] = None,
) -> DeleteApplicationInputProcessingConfigurationResponse

Deletes an InputProcessingConfiguration from an input.

Parameters:

  • application_name (ApplicationName) –

    The name of the application.

  • current_application_version_id (ApplicationVersionId) –

    The application version. You can use the DescribeApplication operation to get the current application version. If the version specified is not the current version, the ConcurrentModificationException is returned.

  • input_id (Id) –

    The ID of the input configuration from which to delete the input processing configuration. You can get a list of the input IDs for an application by using the DescribeApplication operation.

Raises:

Source code in docs_src/capo_kinesis_analytics_v2/_services/async_kinesis_analytics_v2.py 
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
async def delete_application_input_processing_configuration(
    self,
    application_name: "capo_kinesis_analytics_v2.types.application_name.ApplicationName",
    current_application_version_id: "capo_kinesis_analytics_v2.types.application_version_id.ApplicationVersionId",
    input_id: "capo_kinesis_analytics_v2.types.id.Id",
    *,
    config_overrides: Optional[AsyncKinesisAnalyticsV2ClientConfig] = None,
) -> "capo_kinesis_analytics_v2.types.delete_application_input_processing_configuration_response.DeleteApplicationInputProcessingConfigurationResponse":
    """<p>Deletes an <a>InputProcessingConfiguration</a> from an input.</p>

    Args:
        application_name: <p>The name of the application.</p>
        current_application_version_id: <p>The application version. You can use the <a>DescribeApplication</a> operation to get the current application version. If the version specified is not the current version, the <code>ConcurrentModificationException</code> is returned. </p>
        input_id: <p>The ID of the input configuration from which to delete the input processing configuration. You can get a list of the input IDs for an application by using the <a>DescribeApplication</a> operation.</p>

    Raises:
        capo_kinesis_analytics_v2.errors.concurrent_modification_exception.ConcurrentModificationException: <p>Exception thrown as a result of concurrent modifications to an application. This error can be the result of attempting to modify an application without using the current application ID.</p>
        capo_kinesis_analytics_v2.errors.invalid_argument_exception.InvalidArgumentException: <p>The specified input parameter value is not valid.</p>
        capo_kinesis_analytics_v2.errors.invalid_request_exception.InvalidRequestException: <p>The request JSON is not valid for the operation.</p>
        capo_kinesis_analytics_v2.errors.resource_in_use_exception.ResourceInUseException: <p>The application is not available for this operation.</p>
        capo_kinesis_analytics_v2.errors.resource_not_found_exception.ResourceNotFoundException: <p>Specified application can't be found.</p>
        capo_kinesis_analytics_v2.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_kinesis_analytics_v2.types.delete_application_input_processing_configuration_request.DeleteApplicationInputProcessingConfigurationRequest]",
    ) -> AsyncOperationResponse[
        "capo_kinesis_analytics_v2.types.delete_application_input_processing_configuration_response.DeleteApplicationInputProcessingConfigurationResponse"
    ]:
        import capo_kinesis_analytics_v2._operations.kinesis_analytics_20180523.delete_application_input_processing_configuration

        (
            output,
            http_response,
        ) = await capo_kinesis_analytics_v2._operations.kinesis_analytics_20180523.delete_application_input_processing_configuration.async_delete_application_input_processing_configuration(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides,
        OperationLogging("DeleteApplicationInputProcessingConfiguration"),
    )
    input_: capo_kinesis_analytics_v2.types.delete_application_input_processing_configuration_request.DeleteApplicationInputProcessingConfigurationRequest = {
        "application_name": application_name,
        "current_application_version_id": current_application_version_id,
        "input_id": input_id,
    }

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