rov-offline/alg_recsys_coldstart_offlinecheck.py

# -*- coding: utf-8 -*-
import time
import traceback
from config import set_config
from log import Log
from utils import execute_sql_from_odps
from db_helper import RedisHelper
from datetime import datetime, timedelta

from alg_recsys_recall_4h_region_trend import records_process_for_list
config_, _ = set_config()
log_ = Log()
redis_helper = RedisHelper()



def main():
    date_write = ""
    while True:
        date_cur = datetime.now().strftime("%Y-%m-%d %H:%M")
        if "2024-05-07 15:2" in date_cur:
            break
        if date_write == date_cur:
            time.sleep(5)
            continue

        for level in ["1", "2", "3", "4"]:
            key = "flow:pool:level:item:4:" + level
            result = redis_helper.get_data_from_set(key)
            if not result:
                result = []
            size = len(result)
            log_str = "\t".join([date_cur, level, str(size)])
            print(log_str)
        date_write = datetime.now().strftime("%Y-%m-%d %H:%M")


if __name__ == '__main__':
    main()




# cd /root/zhangbo/rov-offline
# nohup python alg_recsys_coldstart_offlinecheck.py > p.log 2>&1 &