worker-development

仓库创建 2024年12月9日最近提交 5 小时前SkillHot 收录 4 小时前

▸ 精选理由

便于添加异步任务并保持队列/调度一致性，适合工程化改动。

这个 Skill 做什么

介绍 ChatbotX 后台 worker、BullMQ 队列与 Kafka 消费者的开发约定。

把异步作业从主进程剥离，开发和维护后台 worker、BullMQ 队列、Kafka 消费者与定时任务，负责任务类型、重试和监控约定。新增队列、实现任务或排查异步故障时会用到，强调幂等性、错误处理和可观察性。特点是统一了进程边界和共享配置，方便扩缩容与故障隔离。

▸ 展开 SKILL.md 英文原文

Create and manage background workers, BullMQ queues, Kafka consumers, and scheduled jobs. Use when adding new workers, creating queues, defining job types, building scheduled tasks, or working with async processing.

开发编程后台任务BullMQKafka通用

524

Stars

116

Forks

仓库内 Skill

积累中

7 日增星

安装 / 使用

给你的 Agent 一句话（通用）

帮我安装这个 skill：https://raw.githubusercontent.com/ChatbotXIO/ChatbotX/main/.agents/skills/worker-development/SKILL.md

或 curl 直取 SKILL.md

curl -fsSL "https://raw.githubusercontent.com/ChatbotXIO/ChatbotX/main/.agents/skills/worker-development/SKILL.md"

SKILL.MD 节选查看完整文件 ↗

# Worker Development

## Architecture

Workers run as separate Node processes in `apps/worker/`. They consume jobs from **BullMQ** queues (Redis-backed) or **Kafka** topics.

**Shared config** lives in `packages/worker-config/` (`@chatbotx.io/worker-config`).

## Existing Workers

| Worker | Queue/Topic | Entry |
|--------|------------|-------|
| integration | `integration` | `src/integration/worker.ts` |
| chat | `chat` | `src/chat/worker.ts` |
| ai-agent | `aiAgent` | `src/ai-agent/worker.ts` |
| default | `default` | `src/default/worker.ts` |
| trigger | `trigger` | `src/trigger/worker.ts` |
| webhook | `webhook` | `src/webhook/worker.ts` |
| schedule | (cron) | `src/schedule/worker.ts` |

via SKILL·HOT · 数据来自 GitHub 公开信息 · 原文版权归作者所有