pump.py 文件源码

def work_every_minute(self, queue, region):
        """
        Handles data for one minute and for one region

        :param queue: the minute ticks for a given day
        :type queue: `Queue`

        :param region: the region to consider
        :type region: `str`

        This is ran as an independant process, so it works asynchronously
        from the rest.
        """

        try:

            for cursor in iter(queue.get, 'STOP'):
                self.tick(cursor, region)
                time.sleep(0.5)

        except KeyboardInterrupt:
            pass
        except:
            raise