crypto.ai/cryptoai/tasks/news.py
2025-06-21 12:31:36 +08:00

40 lines
824 B
Python

from cryptoai.models.user import User
from cryptoai.utils.db_manager import get_db_context, SessionLocal
from sqlalchemy.orm import Session
import logging
import requests
logger = logging.getLogger(__name__)
logger.setLevel(logging.DEBUG)
def task_run():
try:
#dify api
url = "http://ai.meida.fit/v1/workflows/run"
token = "app-ov8ji3bC6WrRlOdNt0cxPyg6"
headers = {
"Authorization": f"Bearer {token}",
"Content-Type": "application/json"
}
payload = {
"inputs": {},
"response_mode": "blocking",
"user": "system",
}
response = requests.post(url, headers=headers, json=payload)
print(response.json())
except Exception as e:
logger.error(f"新闻获取失败: {e}")