Код: Выделить всё
def get_latest_window(resv, start_date):
connection = pymysql.connect(
host=,
port=3306,
user=,
password=,
database=,
charset='utf8mb4',
cursorclass=pymysql.cursors.DictCursor
)
try:
query = """
SELECT *
FROM reservoir_minutely
WHERE facility_id = %s #11
AND collected_at >= %s #'2024-01-01 00:01'
AND collected_at < DATE_ADD(%s, INTERVAL 3 HOUR)
ORDER BY collected_at ASC
"""
print(query)
df = pd.read_sql(query, connection, params=(11, start_date, start_date))
return df
df = get_latest_window(11,'2024-01-01 00:01')
df.head()
Код: Выделить всё
collected_at facility_id press_in flow_in flow_out level degree
0 collected_at facility_id press_in flow_in flow_out level degree
1 collected_at facility_id press_in flow_in flow_out level degree
2 collected_at facility_id press_in flow_in flow_out level degree
3 collected_at facility_id press_in flow_in flow_out level degree
4 collected_at facility_id press_in flow_in flow_out level degree
- collected_at : DATETIME
- facility_id : INT
- press_in : DOUBLE
- flow_in : DOUBLE
- flow_out : DOUBLE
- level : DOUBLE
- степень : DOUBLE

Я также попробовал проверить тип строки в моем фрейме данных и элемент внутри строки. Удивительно, но типы были изменены по мере того, как значения попадали в среду Python.
Код: Выделить всё
print(type(df.iloc[0].iloc[0]))
df.iloc[0].values
Код: Выделить всё
array(['collected_at', 'facility_id', 'press_in', 'flow_in', 'flow_out',
'level', 'degree'], dtype=object)
Подробнее здесь: https://stackoverflow.com/questions/798 ... lumn-names
Мобильная версия