Builds and pushes a Docker image to ECR. Args: app_path: Path to the application directory containing the Dockerfile reposit

Build partition key for lookups

Build sort key for lookups

Authenticate and connect to AWS Transform. Use when the user needs to set up or re-establish a connection. Two modes: - "cookie": imm

Execute a training action for anomaly detection models in AWS IoT SiteWise. This specialized function handles training actions on anomaly detecti

Expand wildcard patterns for service targets with pagination support. Args: targets: List of target dictionaries unix_start: Star

Mock find operation that applies actual filtering. Args: query: Query filter projection: Fields to include/exclude

Generate SVG Gantt chart for tasks. Args: tasks: List of task dictionaries with timing data. Each task should have:

Retrieves cost anomalies using the AWS Cost Explorer GetAnomalies API. Args: ctx: The MCP context ce_client: Cost Explorer client

Get usage metrics for language operations. Args: language_pair: Specific language pair (e.g., "en-es") or None for all

r"""Manage AWS Glue classifiers to determine data formats and schemas. This tool provides operations for AWS Glue classifiers, which help det

Check if the server is running in readonly mode. Returns: True if readonly mode is enabled, False otherwise

Resolve a single content input to its content. Detects the input type and dispatches to the appropriate reader. For inline content in text mo

Execute smart translation workflow with automatic language detection and quality validation. Workflow Steps: 1. Detect source languag

Validate asset ID format - accepts UUID or external ID format.

Validate AWS configuration.

Execute a mutating Valkey command. Write tier — allowlisted mutations only. Destructive commands (FLUSHALL, SHUTDOWN, etc.) are blocked. Disa

Build a ServerConfig for tests.

Normalize run_ids parameter to a list of strings. Handles various input formats: - List of strings: ["run1", "run2"] - JSON string: '["ru

Extract the parsed JSON payload from an MCP result envelope.

Parse ISO 8601 time string to datetime. Assumes UTC if no timezone.

Reload cost_explorer_tools with FastMCP.tool patched to return the original function unchanged (identity decorator). This exposes a callable 'cos

Invoke get_charge_summary for one billing month against a stubbed client. Every case that reaches AWS shares this shape, so it lives here rather

Convert string temporal fields to appropriate datetime objects based on Arrow schema. Args: rows: List of row dictionaries with string te

Create and register an operation prompt with the server. Args: server: MCP server instance api_name: Name of the API oper

Helper method to create test GenomicsFile objects.

Validate LLM-provided content against the component's output schema. Normalize the structure (preprocess) and auto-fill boilerplate.

Get guidance message based on connection status. This function returns appropriate guidance messages for users based on the current status of

Get Amazon Translate client. Returns: boto3 Translate client instance Raises: AuthenticationError: If creden

Handle boto3 ClientError exceptions. Args: ctx: The MCP context e: The ClientError exception operation: The operation tha

Create or retrieve a cached database connection.

Log a message with the request ID from the context. Args: ctx: The MCP context containing the request ID level: The log level (fr

Manage saved SQL queries in AWS Athena. This tool provides operations for creating, retrieving, updating, and deleting named queries

Manage AWS EMR EC2 steps for processing data on EMR clusters. This tool provides comprehensive operations for managing EMR steps, which are u

Normalize exceptions to structured error responses. This function ensures that all exceptions are properly normalized to prevent leaking inte

Set a database connection in the map.

Update config for the current region. None values are ignored. Use clear_config_keys() to explicitly remove keys.

Get a fresh securityagent boto3 client with custom user-agent.

Get all S3 bucket paths including configured and validated adhoc buckets. Args: request: Search request containing potential adho

Add documents to a Valkey Search index with optional embedding generation. Stores documents as Valkey hashes. When embedding_field and text_field

Mock implementation of aws_pricing for testing.

Create one resource and record it in the inventory immediately. Args: resource_type: The category of resource to create.

Delete a value from the cache. Args: key: Cache key Returns: bool: True if the key was found and deleted, Fa

Detect the type of content input. Detection order: 1. If starts with 's3://' -> S3_URI 2. If path passes security checks and exists on fi

Detect the genomics file type from a file path. Args: file_path: The file path to analyze Returns: GenomicsF

Provides comprehensive diagnostic information for a failed workflow run. This function collects multiple sources of diagnostic information includ

Execute a command and return the result. This is a utility function that handles the execution of CLI commands. It sets up the proper environ

Generate all Markdown files and manifest. Returns: Tuple of (list of generated file paths, list of errors) Errors are

Return the currently active credential resolver. Returns: CredentialResolver: The resolver used to produce ``boto3.Session`` instances.

Create and return an AWS service client using boto3's default credential chain. Args: service_name: AWS service name (e.g., 'cloudcontrol

Convert an exception into a structured ErrorResponse. Extracts error code, message, and HTTP status from botocore ClientError. Falls back to

Convert an exception into a structured ErrorResponse. Extracts error code, message, and HTTP status from botocore ClientError. Falls back to

Initiate a pull-through cache by calling batch_get_image. When an image is not found in a pull-through cache repository, calling batch_get_im

Perform basic validation of S3 bucket name format. Args: bucket_name: Bucket name to validate Returns: True if bucket name a

List all available terminologies. Args: max_results: Maximum number of terminologies to return (1-500) next_token: To

Manage AWS Athena data catalogs with both read and write operations. This tool provides operations for managing Athena data catalogs, includi

r"""Manage AWS Glue Resource Policies for access control. This tool allows you to retrieve, create, update, and delete AWS Glue Resource Poli

Execute a full cluster review. Args: cluster_identifier: The cluster identifier to review. execute_query_func: Async callable mat

Send a chat message to the AWS Transform assistant and poll for a response. Polls up to 60s for the assistant's reply. On timeout the result incl

Analyzes source database to extract schema and access patterns for DynamoDB modeling. WHEN TO USE: Call this tool when the user selects "Existing

Stop an SAP application registered with AWS Systems Manager for SAP. For HANA applications with associated NetWeaver (SAP_ABAP) applications,

Validate and resolve a file path before writing a download. Prevents path traversal by stripping directory components from *file_name* via os

Compile wildcard pattern once for reuse. Args: pattern: Wildcard pattern with * for any characters Returns: Compiled regex p

Create a sample pull-through cache rule response object.

Format query result data as Markdown table. Args: data: List of row dictionaries Returns: Markdown table str

Check if text matches pre-compiled wildcard pattern. Args: text: Text to test compiled_pattern: Pre-compiled regex pattern from _

Raise an error requesting user confirmation for write operations.

Async wrapper around the sync Logs Insights poll loop. Wrapping in ``asyncio.to_thread`` keeps the event loop free while the blocking boto3 c

Add a document to the search index. Args: doc: Document to add to the index Note: Extracts and weights diffe

Register an MCP tool with automatic audit logging. Usage: audited_tool(mcp, 'create_job')(self.create_job)

Create and configure the FastMCP server (synchronous wrapper). This is a synchronous convenience wrapper that calls :func:`create_mcp_server_

Create a new custom terminology. Args: name: Terminology name (must be unique) description: Terminology description

Detect the type of README input. Detection rules (in order): 1. If starts with 's3://' -> S3_URI 2. If path exists and ends with '.md' ->

Task-level diagnostics for ECS task failures. Parameters ---------- cluster_name : str The name of the ECS Cluster time_

Format a result dictionary with status and message. This utility function creates a standardized response format used by all the MCP tools. I

Formats a single usage item object from the list_workload_estimate_usage API response. Args: usage_item: Single usage item object from AW

Generate a detailed, downloadable health report for SAP systems managed by SSM for SAP. Produces a comprehensive Markdown-formatted report co

Generate infrastructure code for security scanning before resource creation or update.

Generate a startup script based on runtime and entry point. This script starts up your web server so that beings listening for requests. Args:

Get or create the GLIDE client singleton (thread-safe via asyncio.Lock).

Get enablement guide for AWS Application Signals. Use this tool when the user wants to: - Enable observability, monitoring, or Application Si

Get the results of a completed CloudTrail Lake query with pagination support. This tool retrieves the results of a previously executed CloudT

Convert an exception into a structured ``ErrorResponse``. Args: operation: Friendly name of the API operation that failed. error:

Make a SigV4-signed request to the CloudWatch PromQL API. Args: endpoint: API endpoint path (e.g., 'query', 'query_range', 'label

Create a mock for boto3.client that returns specified clients.

Open the connection pool asynchronously. Args: wait: Whether to wait for connections to be established timeout: Timeo

Auto-paginate a FES list call, collecting all items. Args: operation: FES operation name. body: Request body (not mutated).

Recommend field indexes for a specific CloudWatch log group. Analyzes the last 30 days of completed Logs Insights queries (CWLI, SQL, PPL), i

Request explicit user consent before executing a mutating operation. Raises ValueError if the user rejects or the client doesn't support elicitat

Run a SQL query against Oracle Database.

The implementation of the search_table tool.

Start a cloud browser session via Amazon Bedrock AgentCore. Creates an isolated browser session running in a Firecracker microVM. Ret

Run a diff scan — analyzes only changed code with full repo context. Uploads the committed state at base_ref as the baseline source, and the

Start a workflow run. Args: ctx: MCP context for error reporting workflow_id: ID of the workflow to run role_arn: ARN of

Calculate seasonal strength and extract deseasonalized data for trend. Returns: Tuple of (strength, deseasonalized_values) where

Filter out uninstrumented and aws native services. Args: all_services: List of service summaries from list_services API Returns:

Extract the element ref for a given role and name from snapshot text. Args: snapshot_text: Accessibility tree text from browser_snapshot.