@equental applications/prisma-outbox (英语)

同步 @equationalapplications/core-llm-wiki SQL 将发件箱事件输入您 Prisma 支持的数据库, 使用交易发件箱模式—— 至少一次发送并有订单保证 .

医生 • 妇女 GitHub 图像 • 妇女 范围Lab • 妇女 维基解密 • 妇女 更改日志 • 妇女 问题

投出 SQLite 发包表 @equationalapplications/core-llm-wiki 并同步您 Prisma 支持的系统在 Prisma 交易中的事件, 包含可配置的批量大小、 民意测验间隔、 错误处理和货币保护 .

用于GraphRAG检索表面(traverseGraph, (中文(简体) ), useWikiTraversal, (中文(简体) ), formatGraphContext,参见 GraphRAG 指南。 。 。 .

安装

npm install @equationalapplications/prisma-outbox
# peer deps
npm install @equationalapplications/core-llm-wiki @prisma/client

快开始

import { PrismaOutboxWorker } from '@equationalapplications/prisma-outbox';
import { WikiMemory } from '@equationalapplications/core-llm-wiki';
import { PrismaClient } from '@prisma/client';

const wiki = new WikiMemory(db, {
  llmProvider,
  config: { enableOutbox: true },
});
await wiki.setup();

const prisma = new PrismaClient();

const worker = new PrismaOutboxWorker({
  wikiMemory: wiki,
  prisma,
  mapEvent: async (event, tx) => {
    // mapEvent must be idempotent: at-least-once delivery means the same event
    // can be retried if acknowledgement fails after the Prisma transaction commits.
    if (event.operation === 'INSERT' && event.table_name.includes('entries')) {
      await tx.wikiEntry.upsert({
        where: { id: event.record_id },
        create: { id: event.record_id, ...(event.payload as Record<string, unknown>) },
        update: {},
      });
    }
  },
  pollIntervalMs: 5000,
  batchSize: 100,
  onError: (err, event) => {
    console.error('Outbox event failed', event.id, err);
    return false; // halt to preserve ordering; return true to skip poison-pill
  },
});

worker.start();

// On shutdown:
worker.stop();

API 密码

PrismaOutboxWorker

PrismaOutboxConfig

如何运作

1. 每个 WikiMemory 变异( 当 enableOutbox: true在解剖学上向 SQLite 写一个事件 outbox 表格中与域写入相同的交易.
2. PrismaOutboxWorker 民意调查 getUnprocessedOutboxEvents() 和电话 mapEvent 在每次事件的 Prisma 交易中.
3. 成功处理的事件ID传递给 markOutboxEventsProcessed(),从 SQLite 中删除它们.
4. 如果一个完整的批量被无出错地消耗,即时后续周期会运行(后排优化)以排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排的排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排出排的排出排出排出排出排出排出排出排出排出排出.

限制

• 单入一心. 工人不使用行锁或租赁。 运行两个 PrismaOutboxWorker 与 SQLite 文件相对应的实例将导致重复的 Prisma 写作 。 每个SQLite数据库运行一个工人. mapEvent 仍必须有能力在交货后至少立即予以容忍(在Prisma成功实施后,承认可能失败).

莫诺雷波生态系统

由方程式应用有限责任公司制造. https://equationalapplications.com/ (中文(简体) )