-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathta_bloquear_parciales.py
63 lines (33 loc) · 1.29 KB
/
ta_bloquear_parciales.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
# -*- coding: utf-8 -*-
"""
Created on Fri May 19 11:30:30 2017
@author: Luis Carlos Prieto
"""
import log
import ta_MongoDB
import ta_DataCleaner
def main():
# Variables Generales...
Errores = 0
miLog = log.Log()
GestorMongoDB = ta_MongoDB.MongoDB
miLog.Salidaln("Bienvenido al Manager de cerrado de PARCIALES de MBIT, Iniciando servicios...")
GestorMongoDB = ta_MongoDB.MongoDB()
try:
#Una vez aseguradas las conexiones a BBDD, cargamos los Tweets en formato JSON
GestorMongoDB.CargarJSONNULL()
# Creación del DataCleaner y Volcados a SQL Server
DataCleaner = ta_DataCleaner.DataCleaner(GestorMongoDB.m_ListaJSON)
DataCleaner.CargaTimeline()
# Marcamos los tweets ya cargados para reducir la carga de parciales desde Mongo Azure
GestorMongoDB.PonerParcial(DataCleaner.m_ListaTimeline)
except Exception as e:
Errores += 1
miLog.Salidaln("ERROR cerrando Parciales")
miLog.Salidaln(e.args)
if (Errores > 0 ):
miLog.Salidaln("ERRORES DETECTADOS")
else:
miLog.Salidaln("Proceso finalizado con exito...")
main()