添加redis工具

tools/combine_db/script/import_redis.py

@@ -21,6 +21,8 @@ def writeToRedis(conn, cmdline):
         conn.hset(cmdline[1], cmdline[2], cmdline[3])
     elif cmdline[0] == 'zadd':
         conn.zadd(cmdline[1], {cmdline[3]: cmdline[2]})
+    elif cmdline[0] == 'sadd':
+        conn.sadd(cmdline[1], cmdline[2])
     elif cmdline[0] == 'set':
         conn.set(cmdline[1], cmdline[2])
     else:

tools/logger/game1009newlogger.py

@@ -0,0 +1,31 @@
+# -*- coding: utf-8 -*-
+#!/usr/bin/python
+
+import sys
+sys.path.append('../local_packages')
+import q7
+import f7
+
+import os
+import time
+import json
+import datetime
+
+def saveToDB(conf, savetime):
+    f7.udplog.info('saveToDB begin')
+    try:
+        os.system('python redis_save.py >> redis_save.log')
+    except Exception as e:
+        f7.udplog.info('saveToDB error ' + e)
+        f7.udplog.info('saveToDB end')
+        #进入下一次循环
+    f7.timer.callAt(q7.getDaySeconds(time.time(), 0) + 3600 * 24 + savetime,
+                    lambda : saveToDB(conf, savetime))
+
+if __name__ == "__main__":
+    f7.app.init('/data/logs/game1009newlogger/logs')
+    f7.udplog.info('game1009newlogger start pid:' + str(os.getpid()))
+
+    conf = json.loads(open('../config/game1009newlogger.json', 'r').read())
+    f7.app.listen(conf['listen_port'])
+    f7.app.start()

tools/redis_tools/fetch_data.py

@@ -0,0 +1,42 @@
+# -*- coding: utf-8 -*-
+#!/usr/bin/python
+
+import os
+import sys
+import time
+import json
+import redis
+import pymysql
+import datetime
+import pprint
+from string import Template
+
+argv = sys.argv
+host = argv[1]
+port = argv[2]
+keys = argv[3]
+
+conn = redis.Redis(host = host,
+                   port = port,
+                   db = 0,
+                   decode_responses = True
+)
+
+
+def writeCmdToFile(cmdlist):
+    print(json.dumps(cmdlist))
+
+for redis_key in keys.split(','):
+    if redis_key.strip() == '':
+        continue
+    real_redis_key = redis_key
+    if redis_key[0] == '#':
+        real_redis_key = redis_key[1:]
+        rows = conn.smembers(real_redis_key)
+        for row in rows:
+            writeCmdToFile(['sadd', real_redis_key, row])
+    else:
+        rows = conn.hgetall(real_redis_key)
+        for key in rows.keys():
+            writeCmdToFile(['hset', real_redis_key, key, rows[key]])
+

tools/redis_tools/import_redis.py

@@ -0,0 +1 @@
+../combine_db/script/import_redis.py