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 AM

변경됨

                            estuary_upsert_draft_spec
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_create_draft
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_view_task_logs
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_get_tenant
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_list_roles
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_list_discovers
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_list_publications
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_list_draft_specs
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_list_drafts
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_list_connector_versions
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_list_connectors
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_get_catalog_stats
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_get_catalog_spec
                        

2026년 10월 2일 2:40 AM

변경됨

                            estuary_list_catalog
                        

2026년 10월 2일 2:40 AM

추가됨

                            estuary_publish_draft
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_upsert_draft_spec
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_create_draft
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_view_task_logs
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_get_tenant
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_list_roles
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_list_discovers
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_list_publications
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_list_draft_specs
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_list_drafts
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_list_connector_versions
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_list_connectors
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_get_catalog_stats
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_get_catalog_spec
                        

2026년 9월 30일 2:40 AM

추가됨

                            estuary_list_catalog
                        

2026년 9월 30일 2:40 AM

서버 정보

버전

1.0.0

전송 방식

Streamable HTTP

도구

지연 시간

458 ms

마지막 스캔

2026년 10월 2일 2:40 AM

최초 확인

2026년 9월 30일 2:19 AM

엔드포인트

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

최근 스캔

성공

2026년 10월 2일 2:40 AM

성공

2026년 9월 30일 2:40 AM

estuary-flow

이 MCP로 할 수 있는 일

도구

최근 도구 변경

유사한 MCP 서버

BorealHost

Algenta MCP Server

mcphost

Contabo (VPS) MCP Server

shiply

OSIR Domain Registrar

Fine Structure

mcp