db_model.py 711 B

12345678910111213141516171819
  1. from sqlalchemy import Column, Integer, String, BigInteger, JSON, DateTime, Boolean, func
  2. from sqlalchemy.orm import declarative_base
  3. Base = declarative_base()
  4. class TaskKeyword(Base):
  5. __tablename__ = "wx_trend_keywords"
  6. id = Column(Integer, primary_key=True)
  7. keyword = Column(String(176), unique=True)
  8. is_active = Column(Boolean, default=True)
  9. priority = Column(Integer, default=0)
  10. class WxTrendData(Base):
  11. __tablename__ = "wx_trend_data"
  12. id = Column(BigInteger, primary_key=True)
  13. keyword = Column(String(255))
  14. ymd = Column(String(20))
  15. channel_score = Column(JSON) # 使用 JSON 类型
  16. updated_at = Column(DateTime, server_default=func.now(), onupdate=func.now())