给redis发送消息的脚本
#!/usr/bin/env python3
import redis
from random import randint
pool=redis.ConnectionPool(host='127.0.0.1',port=6379,decode_responses=True)
red=redis.Redis(host='127.0.0.1',port=6379,decode_responses=True)
def random_ip():
ip = []
for x in range(4):
ip.append(str(randint(0,255)))
return '.'.join(ip)
def main():
for num in range(1,50000):
ip=random_ip()
js = '{"clientIP": "'+ ip +'", "type": "country", "ipBlackSec":"3600"}'
print(str(num) + ': ' +js)
with open('iplist.txt','a') as ip_list:
ip_list.write(ip + "
")
red.publish('site:firewall',js)
if __name__ == '__main__':
main()