Estuary Flow MCP by usefulapi

io.usefulapi由 usefulapi.io 发布官方发布者v1.39.2更新于 Nov 14, 2026

Inspect Estuary Flow captures, materializations, collections and stats.

发布方自己的服务:Ably MCP by usefulapi

已验证Streamable HTTP可网页运行云端与基础设施数据与分析

概览

AI 生成的概览

托管式 MCP 服务器,用于查看 Estuary Flow 数据管道:目录实体、规格、吞吐统计、连接器、草稿与发布历史。

可以做什么
  • 列出并读取目录实体(capture、collection、materialization、测试)及其完整规格与编译后规格
  • 按时间范围与粒度获取单个实体的用量与吞吐统计
  • 浏览连接器目录及可用的连接器版本
  • 查看草稿、草稿中暂存的规格、发布历史与发现任务
  • 查询已授予的角色、租户配额与计费档位,并按日志令牌获取任务日志
  • 在草稿中暂存目录变更并发布,默认仅做试运行校验
适用场景
适合让助手回答关于 Estuary Flow 管道的问题,例如当前配置了哪些管道、近期迁移了多少数据、某次发布为何失败,并在发布前把目录修改整理成草稿。
运行要求
远程 streamable HTTP 端点,无需本地安装。登录使用 OAuth,登录页要求填写 Estuary Flow 凭据,凭据按用户存储。不要在客户端配置中添加 Authorization 头或 API 密钥。免费方案每月 50 次工具调用。
安装前请注意
以 dry_run=false 发布草稿具有破坏性,可能创建、修改或删除正在运行的管道及其数据,除非确实要变更,否则保持默认校验。写入类工具会创建草稿并暂存规格。服务器还提供付费方案(Pro、Pro+)、Stripe 结账链接与订阅取消,并会记录功能请求;任何付费或取消操作请自行确认。登录时需输入 Estuary Flow 凭据。

安装

在 SourceWeft 中

  1. 打开 控制台中的 Estuary Flow MCP by usefulapi,将其添加到工作区。
  2. 为需要使用其工具的对话启用该服务。

Web executable,通过 Streamable HTTP。 远程服务在工作区中配置后即可从网页运行时运行。

交给智能体安装

把这段提示词粘贴到 Claude Code、Codex、Cursor 等智能体,或 SourceWeft 对话中。智能体会读取该服务器的安装指南,先向你展示发布者、端点和登录方式,经你同意后再把它添加到你的客户端。密钥不会写进任何命令。

阅读 https://sourceweft.com/mcp/io.usefulapi%2Festuary-flow/install.md,并按其中说明把这个 MCP 服务器接入我的客户端。修改任何配置之前,先告诉我它的发布者、端点和登录方式,等我确认。不要把 API 密钥写进命令或我会提交的文件;问我密钥应从哪里获取。

查看智能体所依据的安装指南

其他 MCP 客户端

把它添加到你客户端的 mcpServers 配置中。

{
  "mcpServers": {
    "estuary-flow-by-usefulapi": {
      "type": "http",
      "url": "https://estuary-flow.usefulapi.io/mcp"
    }
  }
}

README

Estuary Flow MCP by usefulapi

Inspect Estuary Flow captures, materializations, collections and stats. Hosted, no local install.

Live endpoint: https://estuary-flow.usefulapi.io/mcp · Homepage: https://usefulapi.io

Connect

  • Claude (claude.ai, Desktop): open Customize → Connectors, click + Add → Add custom connector, and paste https://estuary-flow.usefulapi.io/mcp.
  • Claude Code: claude mcp add --transport http estuary-flow https://estuary-flow.usefulapi.io/mcp, then run /mcp to log in.
  • VS Code: Add to VS Code.
  • Cursor and other clients: add the URL as a remote MCP server:
json
{  "mcpServers": {    "estuary-flow": {      "url": "https://estuary-flow.usefulapi.io/mcp"    }  }}

Add only the URL. Do not add an Authorization header or an API key to the client config: the server signs you in with OAuth, and the login page asks for your Estuary Flow credentials.

Step-by-step setup, where to find your credentials, and FAQ: https://usefulapi.io/estuary-flow/

On first connect you'll paste your Estuary Flow credentials. They are validated, stored per-user, and scoped to you — no keys in config files.

Tools

ToolTypeWhat it does
estuary_list_catalogreadList catalog entities
estuary_get_catalog_specreadGet catalog spec
estuary_get_catalog_statsreadGet catalog stats
estuary_list_connectorsreadList connectors
estuary_list_connector_versionsreadList connector versions
estuary_list_draftsreadList drafts
estuary_list_draft_specsreadList draft specs
estuary_list_publicationsreadList publications
estuary_list_discoversreadList discovers
estuary_list_rolesreadList roles
estuary_get_tenantreadGet tenant
estuary_view_task_logsreadView task logs
estuary_create_draftwriteCreate draft
estuary_upsert_draft_specwriteUpsert draft spec
estuary_publish_draftwritePublish draft
estuary_flow_usage_statusmetaUsage status (free-tier meter)
estuary_flow_request_featuremetaRequest a missing feature
estuary_flow_upgrademetaUpgrade to Pro or Pro+
estuary_flow_cancel_subscriptionmetaCancel the Pro subscription

read tools are read-only; write tools mutate data (clients should confirm them); meta tools report usage, manage your subscription or send a feature request.

Pricing

PlanPriceLimit
Free$050 tool calls / month
Pro$9/mo or $90/yr (2 months free)10,000 tool calls / month
Pro+$39/mo or $390/yr (2 months free)100,000 tool calls / month

Each paid plan covers this server only. Ask your AI to run estuary_flow_upgrade and choose Pro or Pro+, billed monthly or yearly (it returns a Stripe Checkout link). If you already have Pro, ask to change it to Pro+. The change requires your confirmation, keeps your billing interval and charges the price difference for the rest of the period immediately. Cancel any time with estuary_flow_cancel_subscription: your paid plan continues to the end of the paid period, with no refund for the current period, and asking to resume the same plan with estuary_flow_upgrade before then undoes the cancel. Or write to [email protected].

License

MIT

来源:servers/estuary-flow/README.md,提交 f22f848

工具

15

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.

输入参数limitoffsetspec_typename_prefix

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.

输入参数catalog_name必填

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.

输入参数grainlimitts_endts_startcatalog_name必填

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.

输入参数limitrecommended

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.

输入参数limitconnector_id

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.

输入参数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.

输入参数limitdraft_id必填

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.

输入参数limit

estuary_list_discovers

List discovers

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

输入参数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.

输入参数min_capability

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.

输入参数limit

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.

输入参数bearer_token必填last_logged_at

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.

输入参数detail

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.

输入参数spec必填draft_id必填spec_type必填catalog_name必填

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.

输入参数detaildry_rundraft_id必填

版本历史

26
  1. v1.39.2最新Nov 14, 2026
  2. v1.39.1Nov 13, 2026
  3. v1.38.0Nov 12, 2026
  4. v1.37.3Nov 11, 2026
  5. v1.36.5Nov 8, 2026
  6. v1.36.4Nov 7, 2026
  7. v1.35.3Nov 5, 2026
  8. v1.35.2Nov 5, 2026
  9. v1.35.1Nov 4, 2026
  10. v1.35.0Nov 3, 2026
  11. v1.34.1Nov 3, 2026
  12. v1.33.0Nov 1, 2026
  13. v1.31.0Oct 31, 2026
  14. v1.30.0Oct 31, 2026
  15. v1.29.2Oct 30, 2026
  16. v1.29.0Oct 30, 2026
  17. v1.24.0Oct 26, 2026
  18. v1.21.3Oct 25, 2026
  19. v1.21.0Oct 25, 2026
  20. v1.20.0Oct 24, 2026
  21. v1.17.0Oct 23, 2026
  22. v1.16.4Oct 22, 2026
  23. v1.16.3Oct 21, 2026
  24. v1.11.1Oct 9, 2026
  25. v1.10.0Oct 9, 2026
  26. v1.0.0Sep 29, 2026

评分

已满足适用检查项的 100%

该评分衡量此收录条目的完整程度,依据注册中心条目、端点与公开来源计算得出。它不是对服务器本身的评价,也不表示服务器安全或当前可用:可连通性是带日期的检查结果,评分也不包含安装量或用户评价。

  • 近 30 天内可连通必需25 分
  • 已声明认证方式必需10 分
  • 已列出工具必需15 分
  • 描述必需15 分
  • 图标10 分
  • 文档15 分
  • 许可证10 分

其他 Usefulapi 集成