rboto-bedrock-data-automation

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 Bedrock Data Automation, powered by Rust. This package contains BedrockDataAutomationClient and 27 operations.

Installation

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

python -m pip install "rboto[bedrock-data-automation]"

You can also install rboto-bedrock-data-automation 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 BedrockDataAutomationClient


async def main() -> None:
    client = BedrockDataAutomationClient(region="us-east-1")
    response = await client.list_data_automation_projects(max_results=10)
    for project in response.projects:
        print(project.project_arn, project.project_name)


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 BedrockDataAutomationClient.

• 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_bedrock_data_automation.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_bedrock_data_automation.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_bedrock_data_automation.types; native response definitions are in the package's _native.pyi.

Method	Required arguments	Return type
copy_blueprint_stage	blueprint_arn: str, source_stage: BlueprintStage, target_stage: BlueprintStage	CopyBlueprintStageOutput
create_blueprint	blueprint_name: str, type: Type, schema: str	CreateBlueprintOutput
create_blueprint_version	blueprint_arn: str	CreateBlueprintVersionOutput
create_data_automation_library	library_name: str	CreateDataAutomationLibraryOutput
create_data_automation_project	project_name: str, standard_output_configuration: StandardOutputConfiguration	CreateDataAutomationProjectOutput
delete_blueprint	blueprint_arn: str	DeleteBlueprintOutput
delete_data_automation_library	library_arn: str	DeleteDataAutomationLibraryOutput
delete_data_automation_project	project_arn: str	DeleteDataAutomationProjectOutput
get_blueprint	blueprint_arn: str	GetBlueprintOutput
get_blueprint_optimization_status	invocation_arn: str	GetBlueprintOptimizationStatusOutput
get_data_automation_library	library_arn: str	GetDataAutomationLibraryOutput
get_data_automation_library_entity	library_arn: str, entity_type: EntityType, entity_id: str	GetDataAutomationLibraryEntityOutput
get_data_automation_library_ingestion_job	library_arn: str, job_arn: str	GetDataAutomationLibraryIngestionJobOutput
get_data_automation_project	project_arn: str	GetDataAutomationProjectOutput
invoke_blueprint_optimization_async	blueprint: BlueprintOptimizationObject, samples: Sequence[BlueprintOptimizationSample], output_configuration: BlueprintOptimizationOutputConfiguration, data_automation_profile_arn: str	InvokeBlueprintOptimizationAsyncOutput
invoke_data_automation_library_ingestion_job	library_arn: str, input_configuration: InputConfiguration, entity_type: EntityType, operation_type: LibraryIngestionJobOperationType, output_configuration: OutputConfiguration	InvokeDataAutomationLibraryIngestionJobOutput
list_blueprints	None	ListBlueprintsOutput
list_data_automation_libraries	None	ListDataAutomationLibrariesOutput
list_data_automation_library_entities	library_arn: str, entity_type: EntityType	ListDataAutomationLibraryEntitiesOutput
list_data_automation_library_ingestion_jobs	library_arn: str	ListDataAutomationLibraryIngestionJobsOutput
list_data_automation_projects	None	ListDataAutomationProjectsOutput
list_tags_for_resource	resource_arn: str	ListTagsForResourceOutput
tag_resource	resource_arn: str, tags: Sequence[Tag]	TagResourceOutput
untag_resource	resource_arn: str, tag_keys: Sequence[str]	UntagResourceOutput
update_blueprint	blueprint_arn: str, schema: str	UpdateBlueprintOutput
update_data_automation_library	library_arn: str	UpdateDataAutomationLibraryOutput
update_data_automation_project	project_arn: str, standard_output_configuration: StandardOutputConfiguration	UpdateDataAutomationProjectOutput

Complete signatures

copy_blueprint_stage

async def copy_blueprint_stage(
    *,
    blueprint_arn: str,
    source_stage: BlueprintStage,
    target_stage: BlueprintStage,
    client_token: str | None = None,
) -> CopyBlueprintStageOutput: ...

create_blueprint

async def create_blueprint(
    *,
    blueprint_name: str,
    type: Type,
    schema: str,
    blueprint_stage: BlueprintStage | None = None,
    client_token: str | None = None,
    encryption_configuration: EncryptionConfiguration | None = None,
    tags: Sequence[Tag] | None = None,
) -> CreateBlueprintOutput: ...

create_blueprint_version

async def create_blueprint_version(
    *,
    blueprint_arn: str,
    client_token: str | None = None,
) -> CreateBlueprintVersionOutput: ...

create_data_automation_library

async def create_data_automation_library(
    *,
    library_name: str,
    library_description: str | None = None,
    client_token: str | None = None,
    encryption_configuration: EncryptionConfiguration | None = None,
    tags: Sequence[Tag] | None = None,
) -> CreateDataAutomationLibraryOutput: ...

create_data_automation_project

async def create_data_automation_project(
    *,
    project_name: str,
    standard_output_configuration: StandardOutputConfiguration,
    project_description: str | None = None,
    project_stage: DataAutomationProjectStage | None = None,
    project_type: DataAutomationProjectType | None = None,
    custom_output_configuration: CustomOutputConfiguration | None = None,
    override_configuration: OverrideConfiguration | None = None,
    data_automation_library_configuration: DataAutomationLibraryConfiguration | None = None,
    client_token: str | None = None,
    encryption_configuration: EncryptionConfiguration | None = None,
    tags: Sequence[Tag] | None = None,
) -> CreateDataAutomationProjectOutput: ...

delete_blueprint

async def delete_blueprint(
    *,
    blueprint_arn: str,
    blueprint_version: str | None = None,
) -> DeleteBlueprintOutput: ...

delete_data_automation_library

async def delete_data_automation_library(
    *,
    library_arn: str,
) -> DeleteDataAutomationLibraryOutput: ...

delete_data_automation_project

async def delete_data_automation_project(
    *,
    project_arn: str,
) -> DeleteDataAutomationProjectOutput: ...

get_blueprint

async def get_blueprint(
    *,
    blueprint_arn: str,
    blueprint_version: str | None = None,
    blueprint_stage: BlueprintStage | None = None,
) -> GetBlueprintOutput: ...

get_blueprint_optimization_status

async def get_blueprint_optimization_status(
    *,
    invocation_arn: str,
) -> GetBlueprintOptimizationStatusOutput: ...

get_data_automation_library

async def get_data_automation_library(
    *,
    library_arn: str,
) -> GetDataAutomationLibraryOutput: ...

get_data_automation_library_entity

async def get_data_automation_library_entity(
    *,
    library_arn: str,
    entity_type: EntityType,
    entity_id: str,
) -> GetDataAutomationLibraryEntityOutput: ...

get_data_automation_library_ingestion_job

async def get_data_automation_library_ingestion_job(
    *,
    library_arn: str,
    job_arn: str,
) -> GetDataAutomationLibraryIngestionJobOutput: ...

get_data_automation_project

async def get_data_automation_project(
    *,
    project_arn: str,
    project_stage: DataAutomationProjectStage | None = None,
) -> GetDataAutomationProjectOutput: ...

invoke_blueprint_optimization_async

async def invoke_blueprint_optimization_async(
    *,
    blueprint: BlueprintOptimizationObject,
    samples: Sequence[BlueprintOptimizationSample],
    output_configuration: BlueprintOptimizationOutputConfiguration,
    data_automation_profile_arn: str,
    encryption_configuration: EncryptionConfiguration | None = None,
    tags: Sequence[Tag] | None = None,
) -> InvokeBlueprintOptimizationAsyncOutput: ...

invoke_data_automation_library_ingestion_job

async def invoke_data_automation_library_ingestion_job(
    *,
    library_arn: str,
    input_configuration: InputConfiguration,
    entity_type: EntityType,
    operation_type: LibraryIngestionJobOperationType,
    output_configuration: OutputConfiguration,
    client_token: str | None = None,
    notification_configuration: NotificationConfiguration | None = None,
    tags: Sequence[Tag] | None = None,
) -> InvokeDataAutomationLibraryIngestionJobOutput: ...

list_blueprints

async def list_blueprints(
    *,
    blueprint_arn: str | None = None,
    resource_owner: ResourceOwner | None = None,
    blueprint_stage_filter: BlueprintStageFilter | None = None,
    max_results: int | None = None,
    next_token: str | None = None,
    project_filter: DataAutomationProjectFilter | None = None,
) -> ListBlueprintsOutput: ...

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

list_data_automation_libraries

async def list_data_automation_libraries(
    *,
    max_results: int | None = None,
    next_token: str | None = None,
    project_filter: DataAutomationProjectFilter | None = None,
) -> ListDataAutomationLibrariesOutput: ...

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

list_data_automation_library_entities

async def list_data_automation_library_entities(
    *,
    library_arn: str,
    entity_type: EntityType,
    max_results: int | None = None,
    next_token: str | None = None,
) -> ListDataAutomationLibraryEntitiesOutput: ...

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

list_data_automation_library_ingestion_jobs

async def list_data_automation_library_ingestion_jobs(
    *,
    library_arn: str,
    max_results: int | None = None,
    next_token: str | None = None,
) -> ListDataAutomationLibraryIngestionJobsOutput: ...

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

list_data_automation_projects

async def list_data_automation_projects(
    *,
    max_results: int | None = None,
    next_token: str | None = None,
    project_stage_filter: DataAutomationProjectStageFilter | None = None,
    blueprint_filter: BlueprintFilter | None = None,
    resource_owner: ResourceOwner | None = None,
    library_filter: DataAutomationLibraryFilter | None = None,
) -> ListDataAutomationProjectsOutput: ...

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

list_tags_for_resource

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

tag_resource

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

untag_resource

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

update_blueprint

async def update_blueprint(
    *,
    blueprint_arn: str,
    schema: str,
    blueprint_stage: BlueprintStage | None = None,
    encryption_configuration: EncryptionConfiguration | None = None,
) -> UpdateBlueprintOutput: ...

update_data_automation_library

async def update_data_automation_library(
    *,
    library_arn: str,
    library_description: str | None = None,
    client_token: str | None = None,
) -> UpdateDataAutomationLibraryOutput: ...

update_data_automation_project

async def update_data_automation_project(
    *,
    project_arn: str,
    standard_output_configuration: StandardOutputConfiguration,
    project_stage: DataAutomationProjectStage | None = None,
    project_description: str | None = None,
    custom_output_configuration: CustomOutputConfiguration | None = None,
    override_configuration: OverrideConfiguration | None = None,
    data_automation_library_configuration: DataAutomationLibraryConfiguration | None = None,
    encryption_configuration: EncryptionConfiguration | None = None,
) -> UpdateDataAutomationProjectOutput: ...

Links

• Service guide
• Repository
• Issues
• Releases

Licensed under Apache-2.0.