def search_movie(self, movie):
"""
:param movie: a Movie object with valid fields
:return tweets: A List<twitter.models.Status> containing statuses posted between one year before the movie was
released and the current date if movie is a Movie object
Otherwise returns None
"""
if movie.Title == '' or not isinstance(movie, Movie) or not isinstance(movie.Title,str):
return None
edited_title = self.__clean_title(movie.Title)
imdbID = movie.imdbID
current_datetime = timezone.now()
executor = concurrent.futures.ThreadPoolExecutor(max_workers=7)
futures = []
tweets = []
print('Searching Twitter for ' + edited_title)
for diff in range(0, 6):
futures.append(executor.submit(self._make_request, edited_title, current_datetime, diff, imdbID))
for future in futures:
tweets += future.result()
if tweets == []:
return None
return tweets
# Make the request to Twitter (is run by individual threads)
评论列表
文章目录