Create sample cluster data for testing. Parameters ---------- cluster_name : str Cluster name status : str Clust

Return a list of mutating keywords found in the SQL. The SQL is comment-normalized first so a comment wedged between the words of a multi-wor

Record an error message (no-op for tests).

Comprehensive Kafka ESM troubleshooting tool for both MSK and self-managed Kafka. This unified tool supports both Amazon MSK and self-managed

Create a boto3 S3 Tables client. Args: region_name: Optional AWS region name. If not provided, uses AWS_REGION environment variable

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

Load an OpenAPI specification from a URL or file path. URL fetches are always DNS-pinned: the spec is retrieved by connecting only to the IP

Manage AWS Glue Data Catalog databases with both read and write operations. This tool provides operations for managing Glue Data Catalog data

Create a context manager that mocks boto3.client with the provided client dictionary. Args: mock_clients: Dictionary map

Run a SQL query against Microsoft SQL Server.

Wrap *data* in a ``{success: true, data: ...}`` envelope.

Validate that the SQL is a single permitted statement. Fails closed: oversized input and any parser error are rejected. Args: sql: T

Creates an EC2 jump host instance to access an ElastiCache cluster via SSH tunnel. Args: cache_cluster_id (str): ID of the ElastiCache cl

Creates an EC2 jump host instance to access an ElastiCache serverless cache via SSH tunnel. Args: serverless_cache_name (str): Name of th

Extract details from an exception and return a structured failure. If *error* carries ``status_code`` and ``body`` attributes (e.g. an HttpError)

Filter table rows by matching ALL query words (case-insensitive) across cell values. Handles both flat rows (dict of column→value) and nested row

Handle AWS API errors using boto3's built-in exception information. Leverages boto3's structured error handling as documented at: https://bot

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

Check if a resource is managed by MCP by looking at Tags and Parameters. This method first checks if the resource has the MCP managed tag.

Load configuration from environment variables.

Create a realistic API Gateway proxy event for Lambda.

Create a PymssqlPoolConnection configured for testing.

Save scan state to local storage. Keeps last 50 scans.

Search a Valkey Search index with auto-detected mode. Defaults to hybrid when embeddings are configured, which combines text matching with se

Start a batch translation job with S3 integration. Args: input_config: Configuration for input documents in S3 output

Validate ECR configuration for HealthOmics workflows. Performs a comprehensive validation of the ECR configuration to ensure HealthOmics work

Validate the quality of a translation. This method performs basic validation checks on translation quality, including length ratio an

Return epoch milliseconds for N days ago.

Helper to create a base get_workflow mock response with optional overrides.

Validate input parameters.

Capture an accessibility tree snapshot of the current page. Returns a structured text view of the page with element refs. Use the ref

Complete a Human-in-the-Loop (HITL) task. ⚠️ REQUIRES EXPLICIT USER CONFIRMATION. Before calling this tool you MUST present the full

Check if SQL contains write operations that modify data or schema. This method analyzes SQL queries to detect operations that would modify

Create or retrieve a cached boto3 client with the appropriate profile and region. The client is configured with a custom user agent suffix 'a

Analyze seasonality and extract trend component. Returns: DecompositionResult with seasonality and trend

Helper function to extract data from CallToolResult content.

Format a botocore ClientError into a readable 'Code: Message' string.

Generate DynamoDB entities and repositories from a schema file. Args: schema_path: Path to the schema JSON file output_dir: Outpu

Generate a CDK project from the given JSON file. Args: json_file_path: Path to dynamodb_data_model.json Returns:

Get a database connection from the map.

Get the AWS account ID for the current session. The account ID is cached after the first call to avoid repeated STS calls. Returns:

AWS Client handler with multi-profile support. Args: service_name: AWS service name (e.g., 'logs', 'cloudwatch') region_name: AWS

Get the AWS Timestream for InfluxDB client.

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

Prepare standard tags for a resource. Args: resource_type: The type of resource being created (e.g., 'EMRCluster', 'GlueJob', 'Cr

Scrub sensitive data from a text string. Args: text: The text to scrub Returns: The scrubbed text with sensi

Filter and optimize AWS pricing data for reduced response size. Args: pricing_json_list: List of JSON strings from AWS Pricing API

Validate AWS HealthLake datastore ID format. Requires exactly DATASTORE_ID_LENGTH alphanumeric characters. Used to constrain the value before

Validate a file path before reading. Ensures the path is absolute, resolves symlinks and traversals, and blocks access to sensitive directori

Validate string length constraints. Args: value: The string to validate min_length: Minimum allowed length max_length: Ma

Adds the search_intent query parameter to the search_url if search_intent is a string. :param search_url: URL to be used for search_documentation

Calculate cost and performance metrics from input data.

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

Detect the language of the given text. Args: text: Text to analyze for language detection Returns: LanguageD

Return a list of mutating keywords found in the SQL (excluding comments).

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

Fetch and cache datasets from RODA. Uses the official NDJSON index file which contains all datasets pre-parsed. Thread-safe: uses asyncio.Loc

Get config for the current region.

Get pricing information from AWS Price List API. Args: service_code: The service code (e.g., 'AmazonES' for OpenSearch, 'AmazonS3' for S3

Mock insert_one operation. Args: document: Document to insert Returns: MagicMock: A mock InsertOneResult

List workflow runs. Args: ctx: MCP context for error reporting max_results: Maximum number of results to return (default: 10)

Validate parameter count matches range condition requirements. Args: pattern: AccessPattern object to validate patter

Validate a CloudFormation template using cfn-lint. Args: template_content: CloudFormation template as YAML or JSON string regions

Build common mocks for HealthOmics client, logs, and MCP context. Args: task_count: Number of task events to include. Use 1 for single-ta

Remove SQL comments and string literal contents for security analysis. Parses character-by-character to correctly handle ``--`` and ``/*`` th

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

List AWS invoice summaries for an account or a single invoice. Retrieves invoice-level (header) details without line items. The required API

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

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

Close the pool (no-op).

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