server/game2004api
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2020-08-31 19:36:57 +08:00
parent 5349c6b9f2
commit 851129ab1f
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tools/migratedb/common/redis_rule.json
View File

@ -1,5 +1,5 @@
[ [
{ {
"key_prefix": "" "key_prefix": "game2004"
} }
] ]

5
tools/migratedb/migratedb.py
View File

@ -37,7 +37,6 @@ def scanKeys(r, key_prefix, matched_keys):
#end while cursor #end while cursor
def saveKeys(r, keys, curr_file): def saveKeys(r, keys, curr_file):
print(keys)
for key in keys: for key in keys:
data = r.get(key) data = r.get(key)
curr_file.write(json.dumps({'key': key, 'data':data}) + '\n') curr_file.write(json.dumps({'key': key, 'data':data}) + '\n')
@ -48,13 +47,13 @@ def exportRedis(context, redis_conf, redis_rule_conf):
r = redis.Redis(host = conf['host'], r = redis.Redis(host = conf['host'],
port = conf['port'], port = conf['port'],
password = conf['passwd'], password = conf['passwd'],
charset = 'utf8' decode_responses = True
) )
print(r) print(r)
for rule in redis_rule_conf: for rule in redis_rule_conf:
matched_keys = {} matched_keys = {}
scanKeys(r, rule['key_prefix'], matched_keys) scanKeys(r, rule['key_prefix'], matched_keys)
saveKeys(r, curr_file, matched_keys) saveKeys(r, matched_keys, curr_file)
#end for conf #end for conf
def main(): def main():