crypto.ai/cryptoai/task_endpoint.py
2025-06-04 10:31:44 +08:00

47 lines
1.4 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
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)
schedule.every().day.at("00:00").do(task_run)
while True:
schedule.run_pending()
time.sleep(1)
except Exception as e:
logger.error(f"程序运行出错: {e}")
import traceback
traceback.print_exc()