Mirrors/instaloader
1
0
Fork 0
mirror of https://github.com/instaloader/instaloader.git synced 2024-09-11 16:22:24 +02:00
Code Issues Releases Activity

Wait to avoid error code 429 (Too Many Requests)

Browse Source 
Additional sleeps are necessary because Instagram is rate limiting
GraphQL queries. The error does not occur if not more than 100 queries
are made in a sliding window of eleven minutes.
Fixes #29
This commit is contained in:
André Koch-Kramer 2017-08-12 19:17:18 +02:00
parent 86fb80d7e4
commit a894c2d206
1 changed files with 53 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
instaloader.py
View File

@ -149,6 +149,7 @@ class Instaloader:
self.dirname_pattern = dirname_pattern if dirname_pattern is not None else '{target}'
self.filename_pattern = filename_pattern.replace('{date}', '{date:%Y-%m-%d_%H-%M-%S}') \
if filename_pattern is not None else '{date:%Y-%m-%d_%H-%M-%S}'
self.previous_queries = dict()
def _log(self, *msg, sep='', end='\n', flush=False):
if not self.quiet:
@ -220,13 +221,14 @@ class Instaloader:
return session
def graphql_query(self, query_id: int, variables: Dict[str, Any],
referer: Optional[str] = None) -> Dict[str, Any]:
referer: Optional[str] = None, tries: int = 3) -> Dict[str, Any]:
"""
Do a GraphQL Query.
:param query_id: Query ID.
:param variables: Variables for the Query.
:param referer: HTTP Referer, or None.
:param tries: Number of total tries. Retries if a RequestException occurs.
:return: The server's response dictionary.
"""
tmpsession = copy_session(self.session)
@ -238,13 +240,57 @@ class Instaloader:
tmpsession.headers['accept'] = '*/*'
if referer is not None:
tmpsession.headers['referer'] = referer
sliding_window = 660
def graphql_query_waittime(query_id: int) -> int:
timestamp_list = self.previous_queries.get(query_id)
if not timestamp_list:
return 0
current_time = datetime.now().timestamp()
timestamp_list = list(filter(lambda t: t > current_time - sliding_window, timestamp_list))
self.previous_queries[query_id] = timestamp_list
if len(timestamp_list) < 100:
return 0
return round(min(timestamp_list) + sliding_window - current_time) + 6
waittime = graphql_query_waittime(query_id)
if waittime > 0:
self._log('\nToo many queries in the last time. Need to wait {} seconds.'.format(waittime), flush=True)
time.sleep(waittime)
self._sleep()
response = tmpsession.get('https://www.instagram.com/graphql/query',
params={'query_id': query_id,
'variables': json.dumps(variables, separators=(',', ':'))})
if response.status_code != 200:
raise ConnectionException("GraphQL query returned HTTP error code {}.".format(response.status_code))
return response.json()
try:
response = tmpsession.get('https://www.instagram.com/graphql/query',
params={'query_id': query_id,
'variables': json.dumps(variables, separators=(',', ':'))})
except requests.exceptions.RequestException as err:
print(err, file=sys.stderr)
if tries <= 1:
raise ConnectionException('GraphQL query {} failed multiple times with following variables:\n{}'
.format(query_id, json.dumps(variables, indent=4)))
self._sleep()
return self.graphql_query(query_id, variables, referer, tries - 1)
else:
if response.status_code != 200:
if response.status_code == 429:
print('GraphQL query returned HTTP error code 429 because too many queries occured '
'in the last time.', file=sys.stderr)
waittime = round(min(self.previous_queries.get(query_id))
+ sliding_window - datetime.now().timestamp()) + 6 \
if self.previous_queries.get(query_id) else sliding_window
if waittime > 0:
sys.stderr.flush()
self._log('Please do not use Instagram in your browser or run multiple instances '
'of Instaloader in parallel while using options that require GraphQL '
'queries.\nNeed to wait {} seconds.'.format(waittime), flush=True)
time.sleep(waittime)
return self.graphql_query(query_id, variables, referer, tries)
else:
raise ConnectionException("GraphQL query returned HTTP error code {}.".format(response.status_code))
return response.json()
finally:
timestamp_list = self.previous_queries.get(query_id)
if timestamp_list:
self.previous_queries.get(query_id).append(datetime.now().timestamp())
else:
self.previous_queries[query_id] = [datetime.now().timestamp()]
def get_username_by_id(self, profile_id: int) -> str:
"""To get the current username of a profile, given its unique ID, this function can be used."""