sqlalchemy分表处理

class DeviceOnlineLog(object):
    @staticmethod
    def model(month):
        table_index = month
        class_name = 't_dev_log_%s' % table_index
        engine = get_engine(str=LOG_STRING)
        Base.metadata.reflect(engine)
        table = Table(
            class_name,
            Base.metadata,
            Column('id', Integer, primary_key=True, autoincrement=True),
            Column(
                'devId', Integer, ForeignKey(Device.id), nullable=False),
            Column('onTime', DateTime),
            Column('offTime', DateTime),
            extend_existing=True,
            schema=MYSQL_LOG
        )
        table.create(engine, checkfirst=True)
        return table
class Log(object):
    pass
def mapperClass(cls, table, entity_name, **kw):
    newcls = type(entity_name, (cls, ), {})
    mapper(
        newcls,
        table,
        # non_primary=True,
        # polymorphic_on=table.c.type,
        properties={
           'id': table.c.id,
           'devId': table.c.devId,
           'onTime': table.c.onTime,
           'offTime': table.c.offTime,
        }
    )
    return newcls

from datetime import date
# 初始化session
table_name = date.today().strftime('%Y%m')
table = DeviceOnlineLog.model(table_name)
devId = kwargs.get('id', None)
model = mapperClass(Log, table, 'model')
query = session.query(model).filter_by(devId=devId)