db.py 文件源码

def create_action(self, notification, transport, status=None):
        with self.acquire_conn() as conn:
            create_action_stmt = actions_table.insert().values(
                nid=notification['nid'], transport=transport, status=status)
            result = conn.execute(create_action_stmt)
            return result.inserted_primary_key