Commit a1da3ab3 authored by Yeldar Toktasynov's avatar Yeldar Toktasynov

Changing query to retrieve only strong clusters

parent 0cbcfa34
......@@ -8,7 +8,7 @@ from db_cluster import table_class, create_session
import uuid
import pandas as pd
from sys import getsizeof
from sqlalchemy import or_, and_
logging.basicConfig(format="%(asctime)s %(message)s")
......@@ -32,7 +32,12 @@ logging.info(msg=f"Начало Первого запроса в базу")
session = create_session(**app.config['postgres'])
Class_Table_Name = table_class(app.config['postgres'].get('table_name'))
df = pd.read_sql(session.query(Class_Table_Name.cluster_id, Class_Table_Name.count, Class_Table_Name.centroid)
.filter(Class_Table_Name.is_actual == True, Class_Table_Name.language == 'ru').statement,session.bind)
.filter(Class_Table_Name.is_actual == True, Class_Table_Name.language == 'ru')
.filter(or_(Class_Table_Name.count != 0, and_(Class_Table_Name.count==0,
Class_Table_Name.created_date > datetime.today() - timedelta(days = 30))))
.statement,session.bind)
logging.info(msg=f"Количество кластеров в рус: {len(df)} Size: {getsizeof(df)}")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment