55 lines
1.7 KiB
Python
55 lines
1.7 KiB
Python
#!/usr/bin/env python
|
|
# -*- coding: utf-8 -*-
|
|
|
|
import os
|
|
import sys
|
|
import argparse
|
|
from typing import Dict, Any
|
|
import schedule
|
|
import time
|
|
import logging
|
|
|
|
# 添加项目根目录到Python路径
|
|
current_dir = os.path.dirname(os.path.abspath(__file__))
|
|
parent_dir = os.path.dirname(current_dir)
|
|
sys.path.append(parent_dir)
|
|
|
|
from cryptoai.agents.crypto_agent import CryptoAgent
|
|
from cryptoai.agents.gold_agent import GoldAgent
|
|
from cryptoai.utils.config_loader import ConfigLoader
|
|
from cryptoai.tasks.user import task_run
|
|
from cryptoai.tasks.news import task_run as news_task_run
|
|
logger = logging.getLogger(__name__)
|
|
logger.setLevel(logging.DEBUG)
|
|
|
|
def task_start():
|
|
try:
|
|
|
|
# GoldAgent().start_agent()
|
|
# CryptoAgent().start_agent("WLDUSDT")
|
|
# return
|
|
|
|
# logger.info("🚀 加密货币Agent程序已启动")
|
|
# schedule.every().day.at("00:00").do(CryptoAgent().start_agent)
|
|
schedule.every().day.at("08:00").do(CryptoAgent().start_agent)
|
|
# schedule.every().day.at("12:00").do(CryptoAgent().start_agent)
|
|
# schedule.every().day.at("16:00").do(CryptoAgent().start_agent)
|
|
schedule.every().day.at("20:00").do(CryptoAgent().start_agent)
|
|
|
|
# 每天00:00执行 用户积分复位
|
|
logger.info("积分复位启动")
|
|
schedule.every().day.at("00:00").do(task_run)
|
|
|
|
# 每天08:00执行 新闻获取
|
|
logger.info("新闻获取启动")
|
|
schedule.every().day.at("08:00").do(news_task_run)
|
|
schedule.every().day.at("20:00").do(news_task_run)
|
|
|
|
while True:
|
|
schedule.run_pending()
|
|
time.sleep(1)
|
|
|
|
except Exception as e:
|
|
logger.error(f"程序运行出错: {e}")
|
|
import traceback
|
|
traceback.print_exc() |