测试环境部署

docker run -itd --name redis-test -p 6379:6379 redis:4

pythom demo 生产者

import time
from redis.client import Redis

r = Redis(host='127.0.0.1', port=6379, db=0)

def producer():
    for i in range(10000):
        r.lpush('int_queue', i)

if __name__ == '__main__':
    producer()

pythom demo 消费者

import time
from redis.client import Redis

r = Redis(host='127.0.0.1', port=6379, db=0)

def consumer():
    while True:
        data = r.brpop('int_queue')
        time.sleep(1)
        print(data)

if __name__ == '__main__':
    consumer()

监控部署

wget 'https://github.com/oliver006/redis_exporter/releases/download/v1.52.0/redis_exporter-v1.52.0.linux-amd64.tar.gz'
定义单独key监控
export REDIS_EXPORTER_CHECK_SINGLE_KEYS='int_queue'
nohup ./redis_exporter &

监控查询

curl 127.0.0.1:9121/metrics -s | grep int_queue