MCPサーバー

estuary-flow

            io.usefulapi/estuary-flow
        

クラウド・インフラ公開・接続可能 MCP 2026-07-28

このMCPでできること

Inspects and manages Estuary Flow data pipelines, catalog entities, connectors, drafts, publications, statistics, and task logs.

estuary_create_draft

Create draft

WRITE: create a new empty draft workspace (a staging area for catalog changes; does not affect live pipelines). Estuary control-plane: POST /drafts. Returns the created row.

破壊的操作あり

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'detail': {'type': 'string', 'description': "Optional human-readable note describing the draft's purpose."}}}

estuary_get_catalog_spec

Get catalog spec

Get one live catalog entity by its exact catalog_name, including the full serialized `spec` and compiled `built_spec`. Estuary control-plane view live_specs_ext. PostgREST: GET /live_specs_ext?catalog_name=eq.<name>&limit=1.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['catalog_name'], 'properties': {'catalog_name': {'type': 'string', 'description': 'The exact catalog name (e.g. acmeCo/inventory/products).'}}}

estuary_get_catalog_stats

Get catalog stats

Get usage/throughput stats for one catalog entity — bytes & docs read/written (both directions), usage_seconds, warnings/errors/failures, and txn_count — per time grain. Optionally bound by a timestamp range. Estuary control-plane view catalog_stats. PostgREST: GET /catalog_stats.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['catalog_name'], 'properties': {'grain': {'enum': ['monthly', 'daily', 'hourly'], 'type': 'string', 'description': 'Time grain of each stats row (default daily).'}, 'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}, 'ts_end': {'type': 'string', 'description': 'Filter: stats at/before this ISO 8601 timestamp (ts lte).'}, 'ts_start': {'type': 'string', 'description': 'Filter: stats at/after this ISO 8601 timestamp (ts gte).'}, 'catalog_name': {'type': 'string', 'description': 'The exact catalog name to report stats for.'}}}

estuary_get_tenant

Get tenant

Get the user's tenant(s) — quotas (tasks/collections), billing tiers, recurring charge, trial start, and payment provider. Estuary control-plane table tenants. PostgREST: GET /tenants.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}}}

estuary_list_catalog

List catalog entities

List live catalog entities (captures, collections, materializations, tests) the user can read, with connector + last-publication metadata. Optionally filter by a catalog-name prefix and spec_type. Estuary control-plane view live_specs_ext. PostgREST: GET /live_specs_ext.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}, 'offset': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Row offset for paging (PostgREST offset).'}, 'spec_type': {'enum': ['capture', 'collection', 'materialization', 'test'], 'type': 'string', 'description': 'Filter by entity type.'}, 'name_prefix': {'type': 'string', 'description': 'Filter to catalog names starting with this prefix (PostgREST like.<prefix>* wildcard).'}}}

estuary_list_connectors

List connectors

List the connector catalog — available capture/materialization Docker connectors, with titles, descriptions, and logos. Optionally filter to recommended connectors. Estuary control-plane table connectors. PostgREST: GET /connectors.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}, 'recommended': {'type': 'boolean', 'description': 'Filter to recommended (true) / non-recommended (false) connectors.'}}}

estuary_list_connector_versions

List connector versions

List available versions (image tags) of connectors, with protocol and documentation URL. Optionally filter by connector_id. Estuary control-plane table connector_tags. PostgREST: GET /connector_tags.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}, 'connector_id': {'type': 'string', 'description': 'Filter by connector id (from estuary_list_connectors).'}}}

estuary_list_discovers

List discovers

List connector discovery jobs (auto-detecting bindings/resources for a capture). Estuary control-plane table discovers. PostgREST: GET /discovers.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}}}

estuary_list_drafts

List drafts

List the user's draft workspaces (staging areas for catalog edits before publishing). Estuary control-plane table drafts. PostgREST: GET /drafts.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}}}

estuary_list_draft_specs

List draft specs

List the staged spec entries within a draft (each an insert/replace of a catalog entity pending publication). Estuary control-plane table draft_specs. PostgREST: GET /draft_specs.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['draft_id'], 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}, 'draft_id': {'type': 'string', 'description': 'The draft id to list staged specs for.'}}}

estuary_list_publications

List publications

List publication history/status — each publish attempt of a draft; job_status carries the queued/success/failed outcome. Estuary control-plane table publications. PostgREST: GET /publications.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}}}

estuary_list_roles

List roles

List the roles/capabilities the current credential is granted — which catalog prefixes it can read/write/admin. Read-only RPC. Estuary control-plane: POST /rpc/auth_roles.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'min_capability': {'enum': ['x_00', 'read', 'write', 'admin'], 'type': 'string', 'description': 'Only return grants at/above this capability (default x_00 = all).'}}}

estuary_publish_draft

Publish draft

WRITE (DESTRUCTIVE when dry_run=false): publish a draft. dry_run=true (default) only VALIDATES the draft without changing anything. dry_run=false APPLIES the draft to the LIVE catalog — this can create, modify, or DELETE running data pipelines and their data. Set dry_run=false only when you intend to change live infrastructure. Estuary control-plane: POST /publications. Returns the publication row.

破壊的操作あり

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['draft_id'], 'properties': {'detail': {'type': 'string', 'description': 'Optional human-readable note for this publication.'}, 'dry_run': {'type': 'boolean', 'description': 'If true (DEFAULT), only validate without applying. Set false to APPLY to the live catalog.'}, 'draft_id': {'type': 'string', 'description': 'The draft id to publish.'}}}

estuary_upsert_draft_spec

Upsert draft spec

WRITE: stage (insert or replace) a catalog spec inside a draft. Edits only the draft — live pipelines are unaffected until the draft is published. Estuary control-plane: POST /draft_specs (upsert on draft_id,catalog_name). Returns the staged row.

破壊的操作あり

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['draft_id', 'catalog_name', 'spec_type', 'spec'], 'properties': {'spec': {'type': 'object', 'description': 'The catalog spec JSON object (passed through verbatim).', 'propertyNames': {'type': 'string'}, 'additionalProperties': {}}, 'draft_id': {'type': 'string', 'description': 'The draft id to stage the spec into.'}, 'spec_type': {'enum': ['capture', 'collection', 'materialization', 'test'], 'type': 'string', 'description': 'The entity type of the staged spec.'}, 'catalog_name': {'type': 'string', 'description': 'The catalog name of the entity being staged (e.g. acmeCo/inventory/products).'}}}

estuary_view_task_logs

View task logs

Fetch the log lines for a job by its logs_token (a UUID found on a publication, discover, or connector-tag record). Optionally page from a last-seen timestamp. Read-only RPC. Estuary control-plane: POST /rpc/view_logs.

読み取り専用

入力スキーマ

{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['bearer_token'], 'properties': {'bearer_token': {'type': 'string', 'description': 'The logs_token (UUID) from a publications/discovers/connector_tags row.'}, 'last_logged_at': {'type': 'string', 'description': 'ISO 8601 timestamp — return log lines after this point (2-arg view_logs overload).'}}}

変更

                            estuary_publish_draft
                        

2026年10月2日2:40

変更

                            estuary_upsert_draft_spec
                        

2026年10月2日2:40

変更

                            estuary_create_draft
                        

2026年10月2日2:40

変更

                            estuary_view_task_logs
                        

2026年10月2日2:40

変更

                            estuary_get_tenant
                        

2026年10月2日2:40

変更

                            estuary_list_roles
                        

2026年10月2日2:40

変更

                            estuary_list_discovers
                        

2026年10月2日2:40

変更

                            estuary_list_publications
                        

2026年10月2日2:40

変更

                            estuary_list_draft_specs
                        

2026年10月2日2:40

変更

                            estuary_list_drafts
                        

2026年10月2日2:40

変更

                            estuary_list_connector_versions
                        

2026年10月2日2:40

変更

                            estuary_list_connectors
                        

2026年10月2日2:40

変更

                            estuary_get_catalog_stats
                        

2026年10月2日2:40

変更

                            estuary_get_catalog_spec
                        

2026年10月2日2:40

変更

                            estuary_list_catalog
                        

2026年10月2日2:40

追加

                            estuary_publish_draft
                        

2026年9月30日2:40

追加

                            estuary_upsert_draft_spec
                        

2026年9月30日2:40

追加

                            estuary_create_draft
                        

2026年9月30日2:40

追加

                            estuary_view_task_logs
                        

2026年9月30日2:40

追加

                            estuary_get_tenant
                        

2026年9月30日2:40

追加

                            estuary_list_roles
                        

2026年9月30日2:40

追加

                            estuary_list_discovers
                        

2026年9月30日2:40

追加

                            estuary_list_publications
                        

2026年9月30日2:40

追加

                            estuary_list_draft_specs
                        

2026年9月30日2:40

追加

                            estuary_list_drafts
                        

2026年9月30日2:40

追加

                            estuary_list_connector_versions
                        

2026年9月30日2:40

追加

                            estuary_list_connectors
                        

2026年9月30日2:40

追加

                            estuary_get_catalog_stats
                        

2026年9月30日2:40

追加

                            estuary_get_catalog_spec
                        

2026年9月30日2:40

追加

                            estuary_list_catalog
                        

2026年9月30日2:40

サーバー情報

バージョン

1.0.0

通信方式

Streamable HTTP

ツール

レイテンシ

458 ms

最終スキャン

2026年10月2日2:40

初回確認

2026年9月30日2:19

エンドポイント

https://estuary-flow.usefulapi.io/mcp

estuary-flow

このMCPでできること

ツール

最近のツール変更

類似のMCPサーバー

BorealHost

Algenta MCP Server

mcphost

Contabo (VPS) MCP Server

shiply

OSIR Domain Registrar

Fine Structure

mcp