Redis 5 Streams as readable & writable Node streams. Plus a command line interface.
npm install @derhuerst/redis-stream
Usage:
write-into-redis-stream <stream-name>
Examples:
echo '{"user": "jane", "text": "hey!"}' | write-into-redis-stream chat-msgs
Usage:
read-from-redis-stream <stream-name> [--history] [--live [--waitTimoout <ms>]] [--limit <n>]
Options:
--live Wait for newly added items? Default: true
--waitTimeout -t How long to wait for newly added items. Default: Infinity
--history Read all past items from the stream? Default: false
--limit -l Maximum number of items to read. Default: Infinity
Examples:
read-from-redis-stream chat-msgs --live --limit 1000
const {createClient} = require('redis')
const createWriter = require('@derhuerst/redis-stream/writer')
const redis = createClient()
const writer = createWriter(redis, 'some-stream-name')
writer.once('finish', () => redis.quit())
writer.on('error', console.error)
writer.write({foo: 'bar'})
writer.end({hey: 'there!'})
const {createClient} = require('redis')
const createReader = require('@derhuerst/redis-stream/reader')
const redis = createClient()
const reader = createReader(redis, 'some-stream-name')
reader.on('data', console.log)
reader.on('error', console.error)
Returns a readable stream in object mode.
Returns a readable stream in object mode. opt
may be an object with the following entries:
live
: Wait for newly added items? Default:true
waitTimeout
: How long to wait for newly added items. Default:Infinity
history
: Read all past items from the stream? Default:false
limit
: Maximum number of items to read. Default:Infinity
This project is dual-licensed: My contributions are licensed under the Prosperity Public License, contributions of other people are licensed as Apache 2.0.
This license allows you to use and share this software for noncommercial purposes for free and to try this software for commercial purposes for thirty days.
Personal use for research, experiment, and testing for the benefit of public knowledge, personal study, private entertainment, hobby projects, amateur pursuits, or religious observance, without any anticipated commercial application, doesn’t count as use for a commercial purpose.
Buy a commercial license or read more about why I sell private licenses for my projects.
If you have a question or need support using redis-stream
, please double-check your code and setup first. If you think you have found a bug or want to propose a feature, refer to the issues page.
By contributing, you agree to release your modifications under the Apache 2.0 license.