| 123456789101112131415161718192021222324252627282930313233 |
- #!/usr/bin/python
- # -*- coding=utf-8 -*-
- # @Create Time: 2024-02-21 14:04:06
- # @Last Modified time: 2024-02-26 15:11:01
- from datetime import datetime
- import requests
- from flask import current_app
- from flask_apscheduler import APScheduler
- from .models import Record
- scheduler = APScheduler()
- def dataAnalyze():
- with scheduler.app.app_context():
- redis_store = current_app.redis
- print(datetime.now().strftime('%Y-%m-%d %H:%M:%S'))
- for key in redis_store.keys():
- if 'size' in key and int(redis_store.get(key)) > 1000:
- response = requests.get(f'http://localhost:7788/analyse?user_id={key[:-5]}')
- if response.status_code == 200:
- redis_store.set(key, 0)
- # print(Record.query.filter_by().count())
- def genHeatMap():
- with scheduler.app.app_context():
- redis_store = current_app.redis
- for key in redis_store.keys():
- if 'size' in key and int(redis_store.get(key)) > 10000:
- response = requests.get(f'http://localhost:7788/heatmap?user_id={key[:-5]}')
- if response.status_code == 200:
- redis_store.set(key, 0)
|
