Skip to content

fixed get_mentions wait if rate limit exceeded and retry #30

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
HurinHu wants to merge 1 commit into
base: master
Choose a base branch
from
Open

fixed get_mentions wait if rate limit exceeded and retry #30

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
35 changes: 21 additions & 14 deletions src/bcr_api/bwdata.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,7 @@ def iter_mentions(
"""
params = self._fill_params(name, startDate, kwargs)
page_size = kwargs["pageSize"] if "pageSize" in kwargs else 5000
__delay = kwargs["__delay"] if "__delay" in kwargs else 30
params["pageSize"] = page_size
cursor = params.get("cursor", None)
page_idx = 0
Expand All @@ -77,21 +78,27 @@ def iter_mentions(
break
else:
page_idx += 1
next_cursor, next_mentions = self._get_mentions_page(params)
if len(next_mentions) > 0:
cursor = next_cursor
logger.info(
"Mentions page {} of {} {} retrieved".format(
page_idx, self.resource_type, name
try:
next_cursor, next_mentions = self._get_mentions_page(params)
if len(next_mentions) > 0:
cursor = next_cursor
logger.info(
"Mentions page {} of {} {} retrieved".format(
page_idx, self.resource_type, name
)
)
)
if iter_by_page:
yield next_mentions
else:
for mention in next_mentions:
yield mention
if len(next_mentions) < page_size or not next_cursor:
break
if iter_by_page:
yield next_mentions
else:
for mention in next_mentions:
yield mention
if len(next_mentions) < page_size or not next_cursor:
break
except Exception as e:
if "results" in str(e):
logger.info("Rate limit exceeded, please wait "+str(__delay)+"s ...")
page_idx -= 1
time.sleep(__delay)

def num_mentions(self, name=None, startDate=None, **kwargs):
"""
Expand Down