consumer.py 文件源码

def __init__(self, queue_url, worker, session=None,
                 use_short_polling=False, polling_timeout=10,
                 polling_count=10):
        self.use_short_polling = use_short_polling
        self.polling_timeout = polling_timeout
        self.polling_count = polling_count

        if not session:
            region_name = self.parse_region_name(queue_url)
            session = Session(region_name=region_name)

        self.session = session
        self.sqs = self.session.resource('sqs')
        self.queue = self.sqs.Queue(url=queue_url)

        self.logger = get_logger(__name__)

        self.should_stop = Event()
        self.poller_thread = Thread(group=None, target=self._poll_messages)
        self.worker = worker