Redis Transactions, Pub/Sub, and Streams Cheat Sheet

MULTI

# Queue subsequent commands for EXEC.

EXEC

# Run all queued commands atomically.

DISCARD

# Clear queued transaction commands.

WATCH account:1 account:2

# Abort EXEC if watched keys change before commit.

UNWATCH

# Clear optimistic-lock watches.

WATCH account:1
GET account:1
MULTI
DECRBY account:1 50
INCRBY account:2 50
EXEC

# Common check-and-set transaction workflow.

PUBLISH events:user '{"userId":1,"action":"login"}'

# Send a message to all subscribers of a channel.

SUBSCRIBE events:user events:system

# Listen for messages on one or more channels.

PSUBSCRIBE events:*

# Listen on channels that match a pattern.

UNSUBSCRIBE events:user

# Stop listening to one or more channels.

PUNSUBSCRIBE events:*

# Stop listening to pattern subscriptions.

PUBSUB CHANNELS

# Show active channels with subscribers.

PUBSUB NUMSUB events:user events:system

# Return subscriber counts for channels.

PUBSUB NUMPAT

# Return the total number of active pattern subscriptions.

XADD orders * user_id 1 total 19.99 status paid

# Write a new stream message with autogenerated ID.

XLEN orders

# Return how many entries exist in a stream.

XRANGE orders - + COUNT 10

# Read entries in ascending ID order.

XREVRANGE orders + - COUNT 10

# Read entries in descending ID order.

XREAD COUNT 10 BLOCK 5000 STREAMS orders payments $ $

# Block and read new entries from multiple streams.

XTRIM orders MAXLEN ~ 10000

# Keep the stream approximately within a max length.

XGROUP CREATE orders order-workers $ MKSTREAM

# Create a consumer group, creating the stream if missing.

XREADGROUP GROUP order-workers worker-1 COUNT 10 BLOCK 5000 STREAMS orders >

# Claim new messages for a consumer in a group.

XACK orders order-workers 1710000000000-0

# Acknowledge handled messages in a consumer group.

XPENDING orders order-workers

# View pending entries awaiting acknowledgement.

XCLAIM orders order-workers worker-2 60000 1710000000000-0

# Take ownership of stale pending messages.

XAUTOCLAIM orders order-workers worker-2 60000 0-0 COUNT 100

# Incrementally claim stale pending entries.

XINFO STREAM orders

# Show stream length, first/last IDs, and group counts.

XINFO GROUPS orders

# Show metadata for all groups on a stream.

XDEL orders 1710000000000-0

# Delete one or more stream entries by ID.

GEOADD cities -122.4194 37.7749 sf -74.0060 40.7128 nyc

# Store longitude/latitude points in a sorted set.

GEOPOS cities sf nyc

# Return stored coordinates for members.

GEODIST cities sf nyc km

# Compute the distance between two members.

GEORADIUS cities -122.4194 37.7749 500 km WITHDIST

# Find nearby members around coordinates.

GEOSEARCH cities FROMLONLAT -122.4194 37.7749 BYRADIUS 500 km WITHDIST

# Query nearby members using GEOSEARCH.

PFADD unique:visitors user:1 user:2 user:3

# Approximate cardinality of unique items.

PFCOUNT unique:visitors

# Read approximate unique cardinality.

PFMERGE unique:all unique:web unique:mobile

# Merge approximate cardinality structures.

BITOP AND flags:all flags:a flags:b

# Compute a new bitmap from source bitmaps.

BITPOS feature:flags 1

# Find the offset of the first set bit.