@axiom-lattice/ queue- redis

Axiom Lattice 框架的 Redis 队列客户端执行 .

概览

此软件包提供了一个基于 Redis 的队列客户端执行,符合 QueueClient 界面定义于 @axiom-lattice/protocols。可以与 QueueLatticeManager 从 @axiom-lattice/core 以注册和管理基于 Redis 的队列服务.

安装

pnpm add @axiom-lattice/queue-redis

使用量

基本用途

import { RedisQueueClient } from "@axiom-lattice/queue-redis";
import { registerQueueLattice } from "@axiom-lattice/core";
import { QueueType } from "@axiom-lattice/protocols";

// Register Redis queue service
registerQueueLattice("redis-queue", {
  name: "Redis Queue Service",
  description: "Redis-based queue service",
  type: QueueType.REDIS,
  queueName: "tasks",
  options: {
    redisUrl: process.env.REDIS_URL || "redis://localhost:6379",
    redisPassword: process.env.REDIS_PASSWORD,
  },
});

// Get and use the queue
import { getQueueLattice } from "@axiom-lattice/core";
const queue = getQueueLattice("redis-queue");

// Push item to queue
await queue.push({ task: "example" });

// Pop item from queue
const result = await queue.pop();

直接使用

import { RedisQueueClient } from "@axiom-lattice/queue-redis";

const client = new RedisQueueClient("tasks", {
  redisUrl: "redis://localhost:6379",
  redisPassword: "your-password",
});

// Push item
await client.push({ data: "example" });

// Pop item
const result = await queue.pop();

配置

Redis 队列客户端可以通过 :

1. 构造选项: 传出 redisUrl 财务报告和审定财务报表 redisPassword 直接
2. 环境变量数字 :
   • REDIS_URL (默认 : redis://localhost:6379(中文(简体) )
   • REDIS_PASSWORD (可选)

许可证

麻省理工学院