market-ingest

Market Ingest 用于获取某个交易标的的市场数据，将其归一化为 OHLCV 向量，并使用 HNSW 索引存储，以支持快速的形态搜索。

用途

当你需要摄取某个标的的原始市场数据（价格与成交量），并为其后续的形态检测与相似度搜索做准备时使用。这是运行形态检测或比较之前的第一步。

主要能力与步骤

1. 获取数据：从已配置的数据源（REST API、CSV 文件或手动输入）检索该标的的 OHLCV 数据。

2. 归一化：将原始价格转换为相对值：

• Open: (open - prev_close) / prev_close
• High: (high - open) / open
• Low: (low - open) / open
• Close: (close - open) / open
• Volume: 针对滚动均值/标准差做 Z-score

1. 向量化：将每根 K 线编码为 64 维填充向量（5 个归一化 OHLCV 值 + 填充）。若需要形态描述的语义嵌入，使用 mcp__plugin_ruflo-core_ruflo__embeddings_generate（注意：embeddings_embed 这个工具名并不存在）。

2. 存储：调用 mcp__plugin_ruflo-core_ruflo__memory_store --namespace market-data，以 symbol+date 为键持久化归一化后的 OHLCV 数据。memory_* 工具族按命名空间路由；agentdb_hierarchical-* 工具族按层级（working|episodic|semantic）路由并忽略命名空间字符串，因此此处应使用 memory_*。

3. 索引：调用 mcp__plugin_ruflo-core_ruflo__ruvllm_hnsw_add，将向量加入 HNSW 索引以进行最近邻搜索。

4. 报告：汇总已摄取的 K 线数量、日期范围、价格区间、平均成交量。

CLI 替代方式

npx @claude-flow/cli@latest memory store --namespace market-data --key "symbol-SYMBOL-DATE" --value "OHLCV_JSON"

适用场景

适用于需要为形态检测、相似度搜索或历史行情比较准备数据的场景，尤其是希望以向量形式快速检索相似 K 线形态时。

限制

资料未提供具体支持的数据源清单、支持的标的范围、性能指标、收费方式或平台限制等信息。