counterweight/drogon
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Siguen los retoques. Tests locales exitosos, listo para mover a entorno

Browse source 
de pruebas y dejar corriendo junto a explorer.
This commit is contained in:
pablomartincalvo 2018-10-13 17:45:42 +02:00
parent 6a0baf4de6
commit 4edff2e0c1
7 changed files with 177 additions and 81 deletions
Download patch file Download diff file Expand all files Collapse all files

9
db_layer/capturas_interface.py
View file

@ -10,13 +10,13 @@ class CapturasInterface():
def insert_captura(self, ad_data):
columns = ', '.join(ad_data.keys())
placeholders_string = ', '.join('%s' * len(ad_data))
placeholders_string = ', '.join(['%s'] * len(ad_data))
query_statement = """ INSERT INTO capturas
(%s)
VALUES(%s)""".format(columns, placeholders_string)
( fecha_captura, {} )
VALUES( NOW(), {} )""".format(columns, placeholders_string)
query_parameters = ad_data.values()
query_parameters = tuple([v for v in ad_data.values()])
self.anunciosdb.query(query_statement, query_parameters)
@ -24,4 +24,3 @@ class CapturasInterface():
capturas_interface = CapturasInterface()

14
db_layer/capturing_tasks_interface.py
View file

@ -59,16 +59,18 @@ class CapturingTasksInterface:
self.tasksdb.query(query_statement, query_parameters)
def seconds_since_last_try(self):
query_statement = """SELECT TIME_TO_SEC(TIME_DIFF(now(), write_time))
FROM capturing_task_logs
WHERE status = 'Pending'
query_statement = """SELECT TIME_TO_SEC(TIMEDIFF(now(), write_time))
FROM capturing_tasks_logs
WHERE status = 'Loading'
ORDER BY write_time
LIMIT 1
"""
cursor = self.taskdb.query(query_statement)
return cursor.fetchone()[0]
cursor = self.tasksdb.query(query_statement)
try:
return cursor.fetchone()[0]
except:
return 999
capturing_interface = CapturingTasksInterface()