associate_source_to_s3_table_integration async ¶

async def associate_source_to_s3_table_integration(
    self,
    integration_arn: "capo_cloudwatch_logs.types.arn.Arn",
    data_source: "capo_cloudwatch_logs.types.data_source.DataSource",
    *,
    config_overrides: Optional[AsyncCloudWatchLogsClientConfig] = None,
) -> "capo_cloudwatch_logs.types.associate_source_to_s3_table_integration_response.AssociateSourceToS3TableIntegrationResponse":
    """<p>Associates a data source with an S3 Table Integration for query access in the 'logs' namespace. This enables querying log data using analytics engines that support Iceberg such as Amazon Athena, Amazon Redshift, and Apache Spark.</p>

    Args:
        integration_arn: <p>The Amazon Resource Name (ARN) of the S3 Table Integration to associate the data source with.</p>
        data_source: <p>The data source to associate with the S3 Table Integration. Contains the name and type of the data source.</p>

    Raises:
        capo_cloudwatch_logs.errors.access_denied_exception.AccessDeniedException: <p>You don't have sufficient permissions to perform this action.</p>
        capo_cloudwatch_logs.errors.internal_server_exception.InternalServerException: <p>An internal server error occurred while processing the request. This exception is returned when the service encounters an unexpected condition that prevents it from fulfilling the request.</p>
        capo_cloudwatch_logs.errors.resource_not_found_exception.ResourceNotFoundException: <p>The specified resource does not exist.</p>
        capo_cloudwatch_logs.errors.throttling_exception.ThrottlingException: <p>The request was throttled because of quota limits.</p>
        capo_cloudwatch_logs.errors.validation_exception.ValidationException: <p>One of the parameters for the request is not valid.</p>
        capo_cloudwatch_logs.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_cloudwatch_logs.types.associate_source_to_s3_table_integration_request.AssociateSourceToS3TableIntegrationRequest]",
    ) -> AsyncOperationResponse[
        "capo_cloudwatch_logs.types.associate_source_to_s3_table_integration_response.AssociateSourceToS3TableIntegrationResponse"
    ]:
        import capo_cloudwatch_logs._operations.logs_20140328.associate_source_to_s3_table_integration

        (
            output,
            http_response,
        ) = await capo_cloudwatch_logs._operations.logs_20140328.associate_source_to_s3_table_integration.async_associate_source_to_s3_table_integration(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("AssociateSourceToS3TableIntegration")
    )
    input_: capo_cloudwatch_logs.types.associate_source_to_s3_table_integration_request.AssociateSourceToS3TableIntegrationRequest = {
        "integration_arn": integration_arn,
        "data_source": data_source,
    }

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