nikdoof/test-auth
1
0
Fork 0
mirror of https://github.com/nikdoof/test-auth.git synced 2025-12-14 06:42:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Avoid updating corp information multiple times, add rate limits for API tasks

Browse Source
This commit is contained in:
Andrew Williams
2010-11-10 11:38:32 +00:00
parent 8209f8830c
commit fc7a158352
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
eve_api/tasks.py
View File

@@ -27,7 +27,7 @@ def queue_apikey_updates(update_delay=86400, batch_size=50):
import_apikey.delay(api_key=acc.api_key, api_userid=acc.api_user_id) import_apikey.delay(api_key=acc.api_key, api_userid=acc.api_user_id)
@task() @task(rate_limit='50/m')
def import_apikey(api_userid, api_key, user=None, force_cache=False): def import_apikey(api_userid, api_key, user=None, force_cache=False):
acc = import_eve_account(api_key, api_userid, force_cache=force_cache) acc = import_eve_account(api_key, api_userid, force_cache=force_cache)
donecorps = [] donecorps = []
@@ -39,13 +39,16 @@ def import_apikey(api_userid, api_key, user=None, force_cache=False):
for char in acc.characters.filter(director=1): for char in acc.characters.filter(director=1):
if not char.corporation.id in donecorps: if not char.corporation.id in donecorps:
import_corp_members.delay(api_key=acc.api_key, api_userid=acc.api_user_id, character_id=char.id) import_corp_members.delay(api_key=acc.api_key, api_userid=acc.api_user_id, character_id=char.id)
import_corp_details.delay(corp_id=char.corporation.id)
if char.corporation.api_last_updated < (datetime.datetime.now() - datetime.timedelta(hours=12)):
import_corp_details.delay(corp_id=char.corporation.id)
donecorps.append(char.corporation.id) donecorps.append(char.corporation.id)
for char in acc.characters.all(): for char in acc.characters.all():
try: try:
if char.corporation.id not in donecorps: if char.corporation.id not in donecorps:
import_corp_details.delay(corp_id=char.corporation.id) if char.corporation.api_last_updated < (datetime.datetime.now() - datetime.timedelta(hours=12)):
import_corp_details.delay(corp_id=char.corporation.id)
donecorps.append(char.corporation.id) donecorps.append(char.corporation.id)
except: except:
continue continue
@@ -57,12 +60,12 @@ def import_apikey(api_userid, api_key, user=None, force_cache=False):
return acc return acc
@task(ignore_result=True) @task(ignore_result=True, rate_limit='5/m')
def import_corp_members(api_userid, api_key, character_id): def import_corp_members(api_userid, api_key, character_id):
pull_corp_members(api_key, api_userid, character_id) pull_corp_members(api_key, api_userid, character_id)
@task(ignore_result=True) @task(ignore_result=True, rate_limit='10/m')
def import_corp_details(corp_id): def import_corp_details(corp_id):
corp, created = EVEPlayerCorporation.objects.get_or_create(id=corp_id) corp, created = EVEPlayerCorporation.objects.get_or_create(id=corp_id)
corp.query_and_update_corp() corp.query_and_update_corp()