hlswriter.py 文件源码

def download_binary(self, url, dest_stream):

        log('DOWNLOADING BINARY URI: %s' % url)

        # current_bandwidth_index = self.find_bandwidth_index(self.manifest_playlist,
        #                                                     min(self.maxbitrate, self.average_download_speed))
        # self.selected_bandwidth_index = current_bandwidth_index
        # playlist = self.manifest_playlist.playlists[self.selected_bandwidth_index]
        # self.media_list = self.load_playlist_from_uri(playlist.absolute_uri)

        file = url.split('/')[-1]
        keys = filter(lambda k: k.uri.split('/')[-1] == file, self.media_list.keys)

        if len(keys) <= 0:
            log("ERROR: KEY NOT FOUND: %s | PLAYLIST: %s" % (file, self.media_list.dumps()))
            raise Exception("KEY NOT FOUND: %s" % file)

        self.key = keys[0]
        absolute_uri = self.key.absolute_uri

        log('DOWNLOADING BINARY ABSOLUTE URI: %s' % absolute_uri)

        for chunk in self.__download_chunks(absolute_uri):
            self.__send_back(chunk, dest_stream)