item_feature_clean.py

import json
import os,sys
sys.path.append(os.path.dirname(os.path.abspath(os.path.dirname(__file__))))
import utils.configUtils as configUtils
import utils.connUtils as connUtils


def test():
    VERSION = configUtils.SERVICE_VERSION
    FEATURE_ITEM_KEY = "Strategy:rec:feature:service:" + VERSION + ":item:"
    conn =  connUtils.getRedisConn4()
    keys = conn.keys(FEATURE_ITEM_KEY+"*")
    print("keys size:{}".format(str(len(keys))))
    num = 0
    for k in keys:
        k = str(k,encoding='utf-8')
        v = conn.get(k)
        if v:
            data = json.loads(v,encoding='utf-8')
            if "itemid" in data:
                conn.delete(k)
                num += 1
                print("del {}".format(k))

    print("del size:{}".format(str(num)))

if __name__ == '__main__':
    test()