Multiprocessing parallel push to redis queue python

python_threadpool_push_to_redis_queue.py

import time
from random import random
import json
from multiprocessing import Pool

import redis

r = redis.StrictRedis(host='localhost', port=6379, db=0)
queue_key = 'queue'

parallel = 30
seq = 2500


def push(val):
    for i in range(seq):
        _json = json.dumps({'key': random(), 'val': i * val})
        r.rpush('queue', _json)  # loop here for multiple request sequentially


pool = Pool(10)
start = time.time()
args = (i for i in range(parallel))
pool.map(push, args)
print(f'{parallel * seq} request time {time.time() - start}')