Flyto Core

🚀 flyto-core

flyto-core 是一個可調試的自動化引擎，它能對每一步操作進行追蹤，並支持從任意點開始重放，極大提升了自動化流程的調試和執行效率。

🚀 快速開始

你可以在 30 秒內體驗 flyto-core：

pip install flyto-core[browser] && playwright install chromium
flyto recipe competitor-intel --url https://github.com/pricing

執行上述命令後，會看到如下執行結果：

  Step  1/12  browser.launch         ✓      420ms
  Step  2/12  browser.goto           ✓    1,203ms
  Step  3/12  browser.evaluate       ✓       89ms
  Step  4/12  browser.screenshot     ✓    1,847ms  → saved intel-desktop.png
  Step  5/12  browser.viewport       ✓       12ms  → 390×844
  Step  6/12  browser.screenshot     ✓    1,621ms  → saved intel-mobile.png
  Step  7/12  browser.viewport       ✓        8ms  → 1280×720
  Step  8/12  browser.performance    ✓    5,012ms  → Web Vitals captured
  Step  9/12  browser.evaluate       ✓       45ms
  Step 10/12  browser.evaluate       ✓       11ms
  Step 11/12  file.write             ✓        3ms  → saved intel-report.json
  Step 12/12  browser.close          ✓       67ms

  ✓ Done in 10.3s — 12/12 steps passed

執行完成後，會完成截圖捕獲、性能指標提取以及 JSON 報告保存，並且每一步操作都有詳細追蹤。

✨ 主要特性

• 執行追蹤：對每一步操作進行結構化記錄，包含輸入、輸出、時間和狀態。
• 重放功能：可使用原始（或修改後）的上下文從任意步驟重新執行。
• 斷點設置：能在任意步驟暫停執行，檢查狀態後繼續。
• 證據快照：在每個步驟邊界前後保存完整狀態。
• 數據溯源：跟蹤跨步驟的數據流，構建依賴圖。
• 超時保護：支持可配置的工作流級別和每步超時保護。

📦 安裝指南

pip install flyto-core            # 安裝核心引擎、CLI 和 MCP 服務器
pip install flyto-core[browser]   # 安裝瀏覽器自動化功能（Playwright）
playwright install chromium        # 一次性瀏覽器設置

💻 使用示例

基礎用法

以下是使用 flyto-core 進行競爭定價分析的示例：

name: Competitor Intel
steps:
  - id: launch
    module: browser.launch
  - id: navigate
    module: browser.goto
    params: { url: "{{url}}" }
  - id: prices
    module: browser.evaluate
    params:
      script: |
        JSON.stringify([
          ...document.querySelectorAll(
            '[class*="price"]'
          )
        ].map(e => e.textContent.trim()))
  - id: desktop_shot
    module: browser.screenshot
    params: { path: desktop.png, full_page: true }
  - id: mobile
    module: browser.viewport
    params: { width: 390, height: 844 }
  - id: mobile_shot
    module: browser.screenshot
    params: { path: mobile.png, full_page: true }
  - id: perf
    module: browser.performance
  - id: save
    module: file.write
    params:
      path: report.json
      content: "${prices.result}"
  - id: close
    module: browser.close

高級用法

當第 8 步執行失敗時，可使用以下命令從第 8 步開始重放：

flyto replay --from-step 8

這樣步驟 1 - 7 會立即執行，僅重新執行第 8 步，並且會保留完整上下文。

📚 詳細文檔

3 個立即嘗試的配方

# 競爭定價分析：截圖、Web Vitals 數據和 JSON 報告
flyto recipe competitor-intel --url https://competitor.com/pricing

# 全站審計：SEO、可訪問性和性能
flyto recipe full-audit --url https://your-site.com

# 網頁數據抓取並導出為 CSV
flyto recipe scrape-to-csv --url https://news.ycombinator.com --selector ".titleline a"

每個配方都有執行追蹤，每次運行都可重放。查看所有 32 個配方 →

412 個模塊，78 個類別

查看 完整模塊目錄 以獲取每個模塊、參數和描述的詳細信息。

與其他工具的區別

使用方式

CLI — 從終端運行工作流

# 運行內置配方
flyto recipe site-audit --url https://example.com

# 運行自己的 YAML 工作流
flyto run my-workflow.yaml

# 列出所有配方
flyto recipes

MCP Server — 適用於 Claude Code、Cursor、Windsurf

pip install flyto-core
claude mcp add flyto-core -- python -m core.mcp_server

或者添加到你的 MCP 配置中：

{
  "mcpServers": {
    "flyto-core": {
      "command": "python",
      "args": ["-m", "core.mcp_server"]
    }
  }
}

這樣你的 AI 就能將所有模塊作為工具使用。

HTTP API — 用於集成和遠程執行

pip install flyto-core[api]
flyto serve
# ✓ flyto-core running on 127.0.0.1:8333

Python API — 用於編程式使用

import asyncio
from core.modules.registry import ModuleRegistry

async def main():
    result = await ModuleRegistry.execute(
        "string.reverse",
        params={"text": "Hello"},
        context={}
    )
    print(result)  # {"ok": True, "data": {"result": "olleH"}}

asyncio.run(main())

30 + 內置配方

無需編寫代碼，每個配方都是一個 YAML 工作流模板：

flyto recipes                  # 列出所有配方

# 審計與測試
flyto recipe full-audit       --url https://example.com
flyto recipe competitor-intel --url https://github.com/pricing
flyto recipe site-audit       --url https://example.com
flyto recipe web-perf         --url https://example.com
flyto recipe login-test       --url https://myapp.com/login --username user --password pass --success_selector .dashboard
flyto recipe form-fill        --url https://myapp.com/form --data '{"email":"test@example.com"}'

# 瀏覽器自動化
flyto recipe screenshot        --url https://example.com
flyto recipe responsive-report --url https://example.com
flyto recipe page-to-pdf       --url https://example.com
flyto recipe visual-snapshot   --url https://example.com
flyto recipe webpage-archive   --url https://example.com
flyto recipe scrape-page       --url https://example.com --selector h1
flyto recipe scrape-links      --url https://example.com
flyto recipe scrape-table      --url https://en.wikipedia.org/wiki/YAML --selector .wikitable
flyto recipe stock-price       --symbol AAPL

# 數據與圖像
flyto recipe ocr               --input scan.png
flyto recipe csv-to-json       --input data.csv
flyto recipe image-resize      --input photo.jpg --width 800
flyto recipe image-convert     --input photo.png --format webp

# 網絡與 DevOps
flyto recipe port-scan         --host example.com
flyto recipe whois             --domain example.com
flyto recipe monitor-site      --url https://myapp.com
flyto recipe docker-ps
flyto recipe git-changelog

# 集成
flyto recipe scrape-to-slack   --url https://example.com --selector h1 --webhook $SLACK_URL
flyto recipe github-issue      --url https://example.com --owner me --repo my-app --title "Bug" --token $GITHUB_TOKEN

每個配方都是一個 YAML 工作流模板。運行 flyto recipe <name> --help 可查看完整選項。查看 docs/RECIPES.md 以獲取完整文檔。

編寫自己的工作流

配方只是 YAML 文件，你可以編寫自己的工作流：

name: price-monitor
steps:
  - id: open
    module: browser.launch
    params: { headless: true }

  - id: page
    module: browser.goto
    params: { url: "https://competitor.com/pricing" }

  - id: prices
    module: browser.evaluate
    params:
      script: |
        JSON.stringify([...document.querySelectorAll('.price')].map(e => e.textContent))

  - id: save
    module: file.write
    params: { path: "prices.json", content: "${prices.result}" }

  - id: close
    module: browser.close

flyto run price-monitor.yaml

每次運行都會生成執行追蹤和狀態快照。如果第 3 步失敗，可從第 3 步重放，無需重新運行整個流程。

模塊作者指南

from core.modules.registry import register_module
from core.modules.schema import compose, presets

@register_module(
    module_id='string.reverse',
    version='1.0.0',
    category='string',
    label='Reverse String',
    description='Reverse the characters in a string',
    params_schema=compose(presets.INPUT_TEXT(required=True)),
    output_schema={'result': {'type': 'string', 'description': 'Reversed string'}},
)
async def string_reverse(context):
    text = str(context['params']['text'])
    return {'ok': True, 'data': {'result': text[::-1]}}

查看 模塊規範 以獲取完整指南。

貢獻代碼

我們歡迎貢獻！查看 CONTRIBUTING.md 以獲取貢獻指南。

安全問題

通過 security@flyto.dev 報告安全漏洞。查看 SECURITY.md 以獲取我們的安全策略。

📄 許可證

Apache 許可證 2.0 — 個人和商業使用均免費。

桌面 GUI 可在 flyto2.com 獲取。