rboto-eventbridge

rboto is an independent project maintained by Ferrumio. It is not affiliated with, sponsored by, or endorsed by Amazon Web Services (AWS).

Preview (Alpha). rboto is under active development. APIs may change between releases.

rboto provides an async-only, typed Python client for Amazon EventBridge, powered by Rust. This package contains EventBridgeClient and 57 operations.

Installation

Requires Python 3.12 or newer and a native wheel for your Python version and platform.

python -m pip install "rboto[eventbridge]"

You can also install rboto-eventbridge directly; it installs the matching rboto package. Only the selected service is installed.

These are the package names to use when a release is available on your package index. If your index has no release yet, follow the source installation instructions.

Usage

Configure credentials through your environment, shared profile, or workload role. The example uses us-east-1; select a region where your service and resources are available. Resource names, identifiers, input files, and model IDs in the example are placeholders to replace with your own.

import asyncio

from rboto import EventBridgeClient
from rboto_eventbridge.types import PutEventsRequestEntry


async def main() -> None:
    client = EventBridgeClient(region="us-east-1")
    entry: PutEventsRequestEntry = {
        "event_bus_name": "default",
        "source": "example.orders",
        "detail_type": "OrderCreated",
        "detail": '{"order_id":"123"}',
    }
    response = await client.put_events(entries=[entry])
    if response.failed_entry_count:
        raise RuntimeError(f"Event publication failed: {response.entries}")
    print(response.entries)


if __name__ == "__main__":
    asyncio.run(main())

In an application with an event loop, call await main() instead of asyncio.run(main()). Reuse the client across calls. Constructing a client does not send a request.

API conventions

• Import the client with from rboto import EventBridgeClient.

• Every operation is asynchronous: use await client.method(...).

• Operation arguments are keyword-only and use the Python names listed below.

• Structured inputs use typed dictionaries and tagged unions from rboto_eventbridge.types.

• Regular responses expose typed attributes; response.to_dict() converts them to a dictionary.

• Event-stream responses may be typed dictionaries containing async iterators. Follow the declared return type; consume event streams with async for.

• Byte streams are consumed asynchronously. await stream.read() buffers the complete body; iterate the stream when processing a large response.

• Direct operation calls return one page.

• Use async for page in client.paginators.method(...) for supported paginated operations. Paginators accept the same typed arguments as the corresponding client method.

• Catch modeled exceptions from rboto_eventbridge.exceptions. Their error_code, message, and operation_name identify service failures.

Clients also accept profile, endpoint_url, or shared Session settings. See configuration, errors, and streaming.

Operations

This is the complete operation catalog for this generated package. “Required arguments” lists arguments without defaults in the Python signature. Service-side conditions may require additional arguments. Each method links to its complete signature, including optional arguments. Nested input definitions are in rboto_eventbridge.types; native response definitions are in the package's _native.pyi.

Method	Required arguments	Return type
activate_event_source	name: str	None
cancel_replay	replay_name: str	CancelReplayOutput
create_api_destination	name: str, connection_arn: str, invocation_endpoint: str, http_method: ApiDestinationHttpMethod	CreateApiDestinationOutput
create_archive	archive_name: str, event_source_arn: str	CreateArchiveOutput
create_connection	name: str, authorization_type: ConnectionAuthorizationType, auth_parameters: CreateConnectionAuthRequestParameters	CreateConnectionOutput
create_endpoint	name: str, routing_config: RoutingConfig, event_buses: Sequence[EndpointEventBus]	CreateEndpointOutput
create_event_bus	name: str	CreateEventBusOutput
create_partner_event_source	name: str, account: str	CreatePartnerEventSourceOutput
deactivate_event_source	name: str	None
deauthorize_connection	name: str	DeauthorizeConnectionOutput
delete_api_destination	name: str	DeleteApiDestinationOutput
delete_archive	archive_name: str	DeleteArchiveOutput
delete_connection	name: str	DeleteConnectionOutput
delete_endpoint	name: str	DeleteEndpointOutput
delete_event_bus	name: str	None
delete_partner_event_source	name: str, account: str	None
delete_rule	name: str	None
describe_api_destination	name: str	DescribeApiDestinationOutput
describe_archive	archive_name: str	DescribeArchiveOutput
describe_connection	name: str	DescribeConnectionOutput
describe_endpoint	name: str	DescribeEndpointOutput
describe_event_bus	None	DescribeEventBusOutput
describe_event_source	name: str	DescribeEventSourceOutput
describe_partner_event_source	name: str	DescribePartnerEventSourceOutput
describe_replay	replay_name: str	DescribeReplayOutput
describe_rule	name: str	DescribeRuleOutput
disable_rule	name: str	None
enable_rule	name: str	None
list_api_destinations	None	ListApiDestinationsOutput
list_archives	None	ListArchivesOutput
list_connections	None	ListConnectionsOutput
list_endpoints	None	ListEndpointsOutput
list_event_buses	None	ListEventBusesOutput
list_event_sources	None	ListEventSourcesOutput
list_partner_event_source_accounts	event_source_name: str	ListPartnerEventSourceAccountsOutput
list_partner_event_sources	name_prefix: str	ListPartnerEventSourcesOutput
list_replays	None	ListReplaysOutput
list_rule_names_by_target	target_arn: str	ListRuleNamesByTargetOutput
list_rules	None	ListRulesOutput
list_tags_for_resource	resource_arn: str	ListTagsForResourceOutput
list_targets_by_rule	rule: str	ListTargetsByRuleOutput
put_events	entries: Sequence[PutEventsRequestEntry]	PutEventsOutput
put_partner_events	entries: Sequence[PutPartnerEventsRequestEntry]	PutPartnerEventsOutput
put_permission	None	None
put_rule	name: str	PutRuleOutput
put_targets	rule: str, targets: Sequence[Target]	PutTargetsOutput
remove_permission	None	None
remove_targets	rule: str, ids: Sequence[str]	RemoveTargetsOutput
start_replay	replay_name: str, event_source_arn: str, event_start_time: str, event_end_time: str, destination: ReplayDestination	StartReplayOutput
tag_resource	resource_arn: str, tags: Sequence[Tag]	TagResourceOutput
test_event_pattern	event_pattern: str, event: str	TestEventPatternOutput
untag_resource	resource_arn: str, tag_keys: Sequence[str]	UntagResourceOutput
update_api_destination	name: str	UpdateApiDestinationOutput
update_archive	archive_name: str	UpdateArchiveOutput
update_connection	name: str	UpdateConnectionOutput
update_endpoint	name: str	UpdateEndpointOutput
update_event_bus	None	UpdateEventBusOutput

Complete signatures

activate_event_source

async def activate_event_source(
    *,
    name: str,
) -> None: ...

cancel_replay

async def cancel_replay(
    *,
    replay_name: str,
) -> CancelReplayOutput: ...

create_api_destination

async def create_api_destination(
    *,
    name: str,
    connection_arn: str,
    invocation_endpoint: str,
    http_method: ApiDestinationHttpMethod,
    description: str | None = None,
    invocation_rate_limit_per_second: int | None = None,
) -> CreateApiDestinationOutput: ...

create_archive

async def create_archive(
    *,
    archive_name: str,
    event_source_arn: str,
    description: str | None = None,
    event_pattern: str | None = None,
    retention_days: int | None = None,
    kms_key_identifier: str | None = None,
) -> CreateArchiveOutput: ...

create_connection

async def create_connection(
    *,
    name: str,
    authorization_type: ConnectionAuthorizationType,
    auth_parameters: CreateConnectionAuthRequestParameters,
    description: str | None = None,
    invocation_connectivity_parameters: ConnectivityResourceParameters | None = None,
    kms_key_identifier: str | None = None,
) -> CreateConnectionOutput: ...

create_endpoint

async def create_endpoint(
    *,
    name: str,
    routing_config: RoutingConfig,
    event_buses: Sequence[EndpointEventBus],
    description: str | None = None,
    replication_config: ReplicationConfig | None = None,
    role_arn: str | None = None,
) -> CreateEndpointOutput: ...

create_event_bus

async def create_event_bus(
    *,
    name: str,
    event_source_name: str | None = None,
    description: str | None = None,
    kms_key_identifier: str | None = None,
    dead_letter_config: DeadLetterConfig | None = None,
    log_config: LogConfig | None = None,
    tags: Sequence[Tag] | None = None,
) -> CreateEventBusOutput: ...

create_partner_event_source

async def create_partner_event_source(
    *,
    name: str,
    account: str,
) -> CreatePartnerEventSourceOutput: ...

deactivate_event_source

async def deactivate_event_source(
    *,
    name: str,
) -> None: ...

deauthorize_connection

async def deauthorize_connection(
    *,
    name: str,
) -> DeauthorizeConnectionOutput: ...

delete_api_destination

async def delete_api_destination(
    *,
    name: str,
) -> DeleteApiDestinationOutput: ...

delete_archive

async def delete_archive(
    *,
    archive_name: str,
) -> DeleteArchiveOutput: ...

delete_connection

async def delete_connection(
    *,
    name: str,
) -> DeleteConnectionOutput: ...

delete_endpoint

async def delete_endpoint(
    *,
    name: str,
) -> DeleteEndpointOutput: ...

delete_event_bus

async def delete_event_bus(
    *,
    name: str,
) -> None: ...

delete_partner_event_source

async def delete_partner_event_source(
    *,
    name: str,
    account: str,
) -> None: ...

delete_rule

async def delete_rule(
    *,
    name: str,
    event_bus_name: str | None = None,
    force: bool | None = None,
) -> None: ...

describe_api_destination

async def describe_api_destination(
    *,
    name: str,
) -> DescribeApiDestinationOutput: ...

describe_archive

async def describe_archive(
    *,
    archive_name: str,
) -> DescribeArchiveOutput: ...

describe_connection

async def describe_connection(
    *,
    name: str,
) -> DescribeConnectionOutput: ...

describe_endpoint

async def describe_endpoint(
    *,
    name: str,
    home_region: str | None = None,
) -> DescribeEndpointOutput: ...

describe_event_bus

async def describe_event_bus(
    *,
    name: str | None = None,
) -> DescribeEventBusOutput: ...

describe_event_source

async def describe_event_source(
    *,
    name: str,
) -> DescribeEventSourceOutput: ...

describe_partner_event_source

async def describe_partner_event_source(
    *,
    name: str,
) -> DescribePartnerEventSourceOutput: ...

describe_replay

async def describe_replay(
    *,
    replay_name: str,
) -> DescribeReplayOutput: ...

describe_rule

async def describe_rule(
    *,
    name: str,
    event_bus_name: str | None = None,
) -> DescribeRuleOutput: ...

disable_rule

async def disable_rule(
    *,
    name: str,
    event_bus_name: str | None = None,
) -> None: ...

enable_rule

async def enable_rule(
    *,
    name: str,
    event_bus_name: str | None = None,
) -> None: ...

list_api_destinations

async def list_api_destinations(
    *,
    name_prefix: str | None = None,
    connection_arn: str | None = None,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListApiDestinationsOutput: ...

list_archives

async def list_archives(
    *,
    name_prefix: str | None = None,
    event_source_arn: str | None = None,
    state: ArchiveState | None = None,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListArchivesOutput: ...

list_connections

async def list_connections(
    *,
    name_prefix: str | None = None,
    connection_state: ConnectionState | None = None,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListConnectionsOutput: ...

list_endpoints

async def list_endpoints(
    *,
    name_prefix: str | None = None,
    home_region: str | None = None,
    next_token: str | None = None,
    max_results: int | None = None,
) -> ListEndpointsOutput: ...

list_event_buses

async def list_event_buses(
    *,
    name_prefix: str | None = None,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListEventBusesOutput: ...

list_event_sources

async def list_event_sources(
    *,
    name_prefix: str | None = None,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListEventSourcesOutput: ...

list_partner_event_source_accounts

async def list_partner_event_source_accounts(
    *,
    event_source_name: str,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListPartnerEventSourceAccountsOutput: ...

list_partner_event_sources

async def list_partner_event_sources(
    *,
    name_prefix: str,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListPartnerEventSourcesOutput: ...

list_replays

async def list_replays(
    *,
    name_prefix: str | None = None,
    state: ReplayState | None = None,
    event_source_arn: str | None = None,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListReplaysOutput: ...

list_rule_names_by_target

async def list_rule_names_by_target(
    *,
    target_arn: str,
    event_bus_name: str | None = None,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListRuleNamesByTargetOutput: ...

Also available as client.paginators.list_rule_names_by_target(...), returning an async iterator of the response type above.

list_rules

async def list_rules(
    *,
    name_prefix: str | None = None,
    event_bus_name: str | None = None,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListRulesOutput: ...

Also available as client.paginators.list_rules(...), returning an async iterator of the response type above.

list_tags_for_resource

async def list_tags_for_resource(
    *,
    resource_arn: str,
) -> ListTagsForResourceOutput: ...

list_targets_by_rule

async def list_targets_by_rule(
    *,
    rule: str,
    event_bus_name: str | None = None,
    next_token: str | None = None,
    limit: int | None = None,
) -> ListTargetsByRuleOutput: ...

Also available as client.paginators.list_targets_by_rule(...), returning an async iterator of the response type above.

put_events

async def put_events(
    *,
    entries: Sequence[PutEventsRequestEntry],
    endpoint_id: str | None = None,
) -> PutEventsOutput: ...

put_partner_events

async def put_partner_events(
    *,
    entries: Sequence[PutPartnerEventsRequestEntry],
) -> PutPartnerEventsOutput: ...

put_permission

async def put_permission(
    *,
    event_bus_name: str | None = None,
    action: str | None = None,
    principal: str | None = None,
    statement_id: str | None = None,
    condition: Condition | None = None,
    policy: str | None = None,
) -> None: ...

put_rule

async def put_rule(
    *,
    name: str,
    schedule_expression: str | None = None,
    event_pattern: str | None = None,
    state: RuleState | None = None,
    description: str | None = None,
    role_arn: str | None = None,
    tags: Sequence[Tag] | None = None,
    event_bus_name: str | None = None,
) -> PutRuleOutput: ...

put_targets

async def put_targets(
    *,
    rule: str,
    targets: Sequence[Target],
    event_bus_name: str | None = None,
) -> PutTargetsOutput: ...

remove_permission

async def remove_permission(
    *,
    statement_id: str | None = None,
    remove_all_permissions: bool | None = None,
    event_bus_name: str | None = None,
) -> None: ...

remove_targets

async def remove_targets(
    *,
    rule: str,
    ids: Sequence[str],
    event_bus_name: str | None = None,
    force: bool | None = None,
) -> RemoveTargetsOutput: ...

start_replay

async def start_replay(
    *,
    replay_name: str,
    event_source_arn: str,
    event_start_time: str,
    event_end_time: str,
    destination: ReplayDestination,
    description: str | None = None,
) -> StartReplayOutput: ...

tag_resource

async def tag_resource(
    *,
    resource_arn: str,
    tags: Sequence[Tag],
) -> TagResourceOutput: ...

test_event_pattern

async def test_event_pattern(
    *,
    event_pattern: str,
    event: str,
) -> TestEventPatternOutput: ...

untag_resource

async def untag_resource(
    *,
    resource_arn: str,
    tag_keys: Sequence[str],
) -> UntagResourceOutput: ...

update_api_destination

async def update_api_destination(
    *,
    name: str,
    description: str | None = None,
    connection_arn: str | None = None,
    invocation_endpoint: str | None = None,
    http_method: ApiDestinationHttpMethod | None = None,
    invocation_rate_limit_per_second: int | None = None,
) -> UpdateApiDestinationOutput: ...

update_archive

async def update_archive(
    *,
    archive_name: str,
    description: str | None = None,
    event_pattern: str | None = None,
    retention_days: int | None = None,
    kms_key_identifier: str | None = None,
) -> UpdateArchiveOutput: ...

update_connection

async def update_connection(
    *,
    name: str,
    description: str | None = None,
    authorization_type: ConnectionAuthorizationType | None = None,
    auth_parameters: UpdateConnectionAuthRequestParameters | None = None,
    invocation_connectivity_parameters: ConnectivityResourceParameters | None = None,
    kms_key_identifier: str | None = None,
) -> UpdateConnectionOutput: ...

update_endpoint

async def update_endpoint(
    *,
    name: str,
    description: str | None = None,
    routing_config: RoutingConfig | None = None,
    replication_config: ReplicationConfig | None = None,
    event_buses: Sequence[EndpointEventBus] | None = None,
    role_arn: str | None = None,
) -> UpdateEndpointOutput: ...

update_event_bus

async def update_event_bus(
    *,
    name: str | None = None,
    kms_key_identifier: str | None = None,
    description: str | None = None,
    dead_letter_config: DeadLetterConfig | None = None,
    log_config: LogConfig | None = None,
) -> UpdateEventBusOutput: ...

Links

• Service guide
• Repository
• Issues
• Releases

Licensed under Apache-2.0.