Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
K
KafkaConector30Dias
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Alonso Ballesteros Torres
KafkaConector30Dias
Commits
f286ce1d
Commit
f286ce1d
authored
Jun 28, 2023
by
Alonso Ballesteros Torres
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
- Corrección de error del avance de la fecha local
- Corrección de posible error al cargar una lista vacía de registros
parent
f21ae81e
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
15 additions
and
9 deletions
+15
-9
conector.py
+11
-9
general.py
+4
-0
No files found.
conector.py
View file @
f286ce1d
...
...
@@ -69,12 +69,13 @@ CONEXION_LOCAL: modelos.ConexionSQLite = None
CONEXION_REMOTA
:
modelos
.
ConexionPostgreSQL
=
None
# Variables globales
CAMBIO_DE_DIA
=
False
BASE_ACTUALIZADA
=
False
TRANSACCION_FINALIZADA
=
False
TIEMPO_ANTERIOR
:
float
=
None
DIA_ACTUAL
:
pd
.
Timestamp
=
None
INDICE_KAFKA
:
int
=
None
CAMBIO_DE_DIA
=
False
BASE_ACTUALIZADA
=
False
TRANSACCION_FINALIZADA
=
False
TIEMPO_ANTERIOR
:
float
=
None
DIA_ACTUAL
:
pd
.
Timestamp
=
None
DIA_ACTUALIZACION
:
pd
.
Timestamp
=
None
INDICE_KAFKA
:
int
=
None
# Variables globales de la carga de registros
INSERTADOS
:
List
[
RegistroKafka
]
=
[]
...
...
@@ -175,12 +176,13 @@ def refrescar_dia_actual(fecha_registro: pd.Timestamp, purgar = False):
corresponde a un dia diferente al actual, en cuyo caso se toma como un cambio de dia
'''
global
DIA_ACTUAL
,
CAMBIO_DE_DIA
global
DIA_ACTUAL
,
DIA_ACTUALIZACION
,
CAMBIO_DE_DIA
# Si la fecha del registro es mayor a la fecha actual, se toma como un cambio de dia
if
fecha_registro
>
pd
.
Timestamp
(
DIA_ACTUAL
):
if
purgar
:
print
(
'Purgando registros pendientes...
\n
'
)
DIA_ACTUALIZACION
=
DIA_ACTUAL
DIA_ACTUAL
=
fecha_registro
CAMBIO_DE_DIA
=
True
...
...
@@ -327,8 +329,8 @@ def ciclo():
print
(
'Cambio de dia detectado...
\n
'
)
CAMBIO_DE_DIA
=
False
# Se actualiza la base de datos remota hasta que se alcance el d
ia actual
while
FECHA_LOCAL
<
DIA_ACTUAL
:
# Se actualiza la base de datos remota hasta que se alcance el d
ía de actualización
while
FECHA_LOCAL
<
DIA_ACTUAL
IZACION
:
print
(
'Día local: '
,
FECHA_LOCAL
.
actual
.
date
())
print
(
'Actualizando la base de datos local y remota...'
)
...
...
general.py
View file @
f286ce1d
...
...
@@ -132,6 +132,10 @@ def cargar_valores_reales(conexion: Conexion, registros: pd.DataFrame, fecha: pd
datos
=
[]
# Si no hay registros, no se hace nada
if
len
(
registros
)
==
0
:
return
# Se obtienen los casos confirmados para cada tipo de valor
for
tipo
in
TIPO_VALOR
:
confirmados
=
calcular_confirmados
(
registros
,
tipo
,
fecha
)
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment