put_raw_events async ¶

async def put_raw_events(
    self,
    event_bus_arn: "capo_eventbridgev2.types.event_bus_arn.EventBusArn",
    entries: "capo_eventbridgev2.types.put_raw_events_request_entry_list.PutRawEventsRequestEntryList",
    *,
    config_overrides: Optional[AsyncEventBridgeV2ClientConfig] = None,
    schema_registry_configuration: Optional[
        "capo_eventbridgev2.types.schema_registry_configuration.SchemaRegistryConfiguration"
    ] = None,
    deduplication_configuration: Optional[
        "capo_eventbridgev2.types.deduplication_configuration.DeduplicationConfiguration"
    ] = None,
) -> "capo_eventbridgev2.types.put_raw_events_response.PutRawEventsResponse":
    """Publishes pre-shaped events to an event bus.

    Args:
        schema_registry_configuration: Schema-registry settings for encoding open-format (Avro/Protobuf) events. Required for open-format entries; ignored for JSON entries. The registry is read with the caller's credentials, so the caller needs read access to the registry it references.
        deduplication_configuration: Request-level deduplication settings, applied to every entry in the batch.

    Raises:
        capo_eventbridgev2.errors.access_denied_exception.AccessDeniedException: The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
        capo_eventbridgev2.errors.internal_exception.InternalException: The request failed because of an internal service error. Retry the request.
        capo_eventbridgev2.errors.invalid_input_exception.InvalidInputException: A request parameter is missing or not valid.
        capo_eventbridgev2.errors.throttling_exception.ThrottlingException: The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
        capo_eventbridgev2.errors.invalid_state_exception.InvalidStateException: The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
        capo_eventbridgev2.errors.resource_not_found_exception.ResourceNotFoundException: The resource does not exist.
        capo_eventbridgev2.errors.schema_registry_unavailable_exception.SchemaRegistryUnavailableException: The configured schema registry could not be reached. Retry the request.
        capo_eventbridgev2.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_eventbridgev2.types.put_raw_events_request.PutRawEventsRequest]",
    ) -> AsyncOperationResponse[
        "capo_eventbridgev2.types.put_raw_events_response.PutRawEventsResponse"
    ]:
        import capo_eventbridgev2._operations.aws_events_v2.put_raw_events

        (
            output,
            http_response,
        ) = await capo_eventbridgev2._operations.aws_events_v2.put_raw_events.async_put_raw_events(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    def _redact_input(
        input_: "capo_eventbridgev2.types.put_raw_events_request.PutRawEventsRequest",
    ) -> dict[str, Any]:
        import capo_eventbridgev2.types.put_raw_events_request

        return capo_eventbridgev2.types.put_raw_events_request.redact_sensitive(
            input_
        )

    interceptors_, options_ = self.operation_options(
        config_overrides,
        OperationLogging("PutRawEvents", redact_input=_redact_input),
    )
    input_: capo_eventbridgev2.types.put_raw_events_request.PutRawEventsRequest = {
        "event_bus_arn": event_bus_arn,
        "entries": entries,
    }
    if schema_registry_configuration is not None:
        input_["schema_registry_configuration"] = schema_registry_configuration
    if deduplication_configuration is not None:
        input_["deduplication_configuration"] = deduplication_configuration

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