| 123456789101112131415161718192021 |
- # coding: utf-8
- from sqlalchemy import Column, String
- from sqlalchemy.dialects.mysql import INTEGER
- from sqlalchemy.ext.declarative import declarative_base
- Base = declarative_base()
- metadata = Base.metadata
- class DbKafka(Base):
- __tablename__ = 'db_kafka'
- id = Column(INTEGER(11), primary_key=True)
- name = Column(String(200), nullable=False)
- json_str = Column(String(5000), nullable=False)
- def to_dict(self):
- return {c.name: getattr(self, c.name, None) for c in self.__table__.columns}
- def __repr__(self):
- return str(self.to_dict())
|
