大数据中台在兰州的应用与实践

import pandas as pd

from sqlalchemy import create_engine

def fetch_data_from_db(query):

engine = create_engine('mysql+pymysql://username:password@localhost/dbname')

return pd.read_sql_query(query, engine)

# 示例查询

query = "SELECT * FROM traffic_data WHERE city='Lanzhou'"

traffic_df = fetch_data_from_db(query)

print(traffic_df.head())

]]>

traffic_df.dropna(inplace=True) # 删除缺失值

traffic_df = traffic_df[traffic_df['speed'] > 0] # 过滤异常速度

]]>

from tensorflow.keras.models import Sequential

from tensorflow.keras.layers import LSTM, Dense

model = Sequential()

model.add(LSTM(50, activation='relu', input_shape=(n_steps, n_features)))

model.add(Dense(1))

model.compile(optimizer='adam', loss='mse')

# 模型训练...

]]>