This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which only supports SQL applications. Version 2 of the API supports SQL and Java applications. For more information about version 2, see Amazon Kinesis Data Analytics API V2 Documentation.
Deletes the specified application. Amazon Kinesis Analytics halts application execution and deletes the application, including any application artifacts (such as in-application streams, reference table, and application code).
This operation requires permissions to perform the kinesisanalytics:DeleteApplication action.
Parameters:
-
application_name
(ApplicationName)
–
Name of the Amazon Kinesis Analytics application to delete.
-
create_timestamp
(Timestamp)
–
You can use the DescribeApplication operation to get this value.
Raises:
Source code in docs_src/capo_kinesis_analytics/_services/async_kinesis_analytics.py
| async def delete_application(
self,
application_name: "capo_kinesis_analytics.types.application_name.ApplicationName",
create_timestamp: "capo_kinesis_analytics.types.timestamp.Timestamp",
*,
config_overrides: Optional[AsyncKinesisAnalyticsClientConfig] = None,
) -> "capo_kinesis_analytics.types.delete_application_response.DeleteApplicationResponse":
"""<note> <p>This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which only supports SQL applications. Version 2 of the API supports SQL and Java applications. For more information about version 2, see <a href="/kinesisanalytics/latest/apiv2/Welcome.html">Amazon Kinesis Data Analytics API V2 Documentation</a>.</p> </note> <p>Deletes the specified application. Amazon Kinesis Analytics halts application execution and deletes the application, including any application artifacts (such as in-application streams, reference table, and application code).</p> <p>This operation requires permissions to perform the <code>kinesisanalytics:DeleteApplication</code> action.</p>
Args:
application_name: <p>Name of the Amazon Kinesis Analytics application to delete.</p>
create_timestamp: <p> You can use the <code>DescribeApplication</code> operation to get this value. </p>
Raises:
capo_kinesis_analytics.errors.concurrent_modification_exception.ConcurrentModificationException: <p>Exception thrown as a result of concurrent modification to an application. For example, two individuals attempting to edit the same application at the same time.</p>
capo_kinesis_analytics.errors.resource_in_use_exception.ResourceInUseException: <p>Application is not available for this operation.</p>
capo_kinesis_analytics.errors.resource_not_found_exception.ResourceNotFoundException: <p>Specified application can't be found.</p>
capo_kinesis_analytics.errors.unsupported_operation_exception.UnsupportedOperationException: <p>The request was rejected because a specified parameter is not supported or a specified resource is not valid for this operation. </p>
capo_kinesis_analytics.errors.UnknownServiceError: The service returned an error code this client does not model.
"""
async def _handler(
req: "AsyncOperationRequest[capo_kinesis_analytics.types.delete_application_request.DeleteApplicationRequest]",
) -> AsyncOperationResponse[
"capo_kinesis_analytics.types.delete_application_response.DeleteApplicationResponse"
]:
import capo_kinesis_analytics._operations.kinesis_analytics_20150814.delete_application
(
output,
http_response,
) = await capo_kinesis_analytics._operations.kinesis_analytics_20150814.delete_application.async_delete_application(
req.options, req.input
)
return AsyncOperationResponse(output=output, response=http_response)
interceptors_, options_ = self.operation_options(
config_overrides, OperationLogging("DeleteApplication")
)
input_: capo_kinesis_analytics.types.delete_application_request.DeleteApplicationRequest = {
"application_name": application_name,
"create_timestamp": create_timestamp,
}
response = await aexecute_pipeline(
AsyncOperationRequest(input=input_, options=options_),
handler=_handler,
interceptors=list(interceptors_),
)
await response.response.aclose()
return response.output
|