create_compliance_inquiry async ¶

async def create_compliance_inquiry(
    self,
    name: "capo_artifact.types.inquiry_name.InquiryName",
    inquiry_content: "capo_artifact.types.inquiry_content.InquiryContent",
    *,
    config_overrides: Optional[AsyncArtifactClientConfig] = None,
    client_token: Optional[
        "capo_artifact.types.idempotent_client_token.IdempotentClientToken"
    ] = None,
    support_mode: Optional[
        "capo_artifact.types.inquiry_support_mode.InquirySupportMode"
    ] = None,
    tags: Optional["capo_artifact.types.tags_map.TagsMap"] = None,
) -> "capo_artifact.types.create_compliance_inquiry_response.CreateComplianceInquiryResponse":
    """<p>Create a new compliance inquiry.</p>

    Args:
        name: <p>Title of the inquiry.</p>
        inquiry_content: <p>Content for creating a compliance inquiry - either a single query or file content.</p>
        client_token: <p>Idempotency token for the request.</p>
        support_mode: <p>Support mode for inquiry processing. Only supported for file upload mode. Defaults to AI_ONLY if not specified.</p>
        tags: <p>Tags to associate with the compliance inquiry resource.</p>

    Raises:
        capo_artifact.errors.access_denied_exception.AccessDeniedException: <p>User does not have sufficient access to perform this action.</p>
        capo_artifact.errors.conflict_exception.ConflictException: <p>Request to create/modify content would result in a conflict.</p>
        capo_artifact.errors.internal_server_exception.InternalServerException: <p>An unknown server exception has occurred.</p>
        capo_artifact.errors.throttling_exception.ThrottlingException: <p>Request was denied due to request throttling.</p>
        capo_artifact.errors.validation_exception.ValidationException: <p>Request fails to satisfy the constraints specified by an AWS service.</p>
        capo_artifact.errors.UnknownServiceError: The service returned an error code this client does not model.

    Examples:
        Invoke CreateComplianceInquiry operation
        Creates a compliance inquiry with a single text query.

        >>> await client.create_compliance_inquiry(name='My Compliance Inquiry', inquiry_content={'query': 'Is my workload compliant with SOC 2?'}, client_token='unique-client-token-1234', support_mode='AI_ONLY')
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_artifact.types.create_compliance_inquiry_request.CreateComplianceInquiryRequest]",
    ) -> AsyncOperationResponse[
        "capo_artifact.types.create_compliance_inquiry_response.CreateComplianceInquiryResponse"
    ]:
        import capo_artifact._operations.artifact.create_compliance_inquiry

        (
            output,
            http_response,
        ) = await capo_artifact._operations.artifact.create_compliance_inquiry.async_create_compliance_inquiry(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    def _redact_input(
        input_: "capo_artifact.types.create_compliance_inquiry_request.CreateComplianceInquiryRequest",
    ) -> dict[str, Any]:
        import capo_artifact.types.create_compliance_inquiry_request

        return (
            capo_artifact.types.create_compliance_inquiry_request.redact_sensitive(
                input_
            )
        )

    interceptors_, options_ = self.operation_options(
        config_overrides,
        OperationLogging("CreateComplianceInquiry", redact_input=_redact_input),
    )
    input_: capo_artifact.types.create_compliance_inquiry_request.CreateComplianceInquiryRequest = {
        "name": name,
        "inquiry_content": inquiry_content,
    }
    if client_token is None:
        client_token = str(uuid.uuid4())
    input_["client_token"] = client_token
    if support_mode is not None:
        input_["support_mode"] = support_mode
    if tags is not None:
        input_["tags"] = tags

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