feeder.py 文件源码

def task(self):
        get_logger().info(f"Feeding Router intraday average_prices from database")

        for table in self.intraday_tables:
            try:
                query = f"SELECT symbol, price FROM `{table}` ORDER BY datetime"
                cursor = database.connect('yquant_intraday').cursor(SSCursor)
                cursor.execute(query)

                get_logger().info(f"Sending average_prices on {table} to Router")
                for row in cursor:
                    # get_logger().debug(f"{row[0]} {row[1]}")
                    self.sockets['Router'].send_string(f'PRICE {row[0]} {row[1]}')

            except pymysql.err.ProgrammingError as e:
                if "doesn't exist" in str(e):
                    get_logger().error(f"Table [{table}] doesn't exist")

        self.sockets['Router'].send_string(f'END')