import redis
import time
pool=redis.ConnectionPool(host='xxxxxxx', port=6379, max_connections=100)
r = redis.StrictRedis(connection_pool=pool)
def del_keys_with_pipe():
start_time = time.time()
result_length = 0
pipe = r.pipeline()
for key in r.scan_iter(match='sociaxx*', count=2000):
pipe.delete(key)
result_length += 1
if result_length % 2000 == 0:
pipe.execute()
ip_time = time.time()
print("use pipeline scan time :", time.time() - start_time)
pipe.execute()
print ("use pipeline ways delete numbers:", result_length)
if __name__ == '__main__':
del_keys_with_pipe()