slack_archive.py 文件源码

def fetch_public_messages(self):
        self.log.info('Fetching public channels messages')
        self.create_messages_indices()
        try:
            chans_list = self.api_handle.channels.list().body
            random.shuffle(chans_list['channels'])
            SlackArchive.api_call_delay()
        except Error as err:
            self.mongo.db.z_errors.insert_one({'_id': time.time(),
                                               'ctx': 'fetch_public_messages',
                                               'msg': str(err)})
            self.log.exception('Fetch public messages error %s', str(err))
            return

        self.update_streams(chans_list)
        api_loader = functools.partial(self.api_handle.channels.history,
                                       inclusive=0, count=1000)
        self._fetch_stream_messages(api_loader, chans_list['channels'])