import pandas as pd
# 示例代码：读取CSV文件并查看前几行
data = pd.read_csv('traffic_data.csv')
print(data.head())
]]>
from pyspark.sql import SparkSession
# 初始化Spark会话
spark = SparkSession.builder \
.appName("HebeiDataPlatform") \
.getOrCreate()
# 加载数据
df = spark.read.format("csv").option("header", "true").load("traffic_data.csv")
# 显示数据概览
df.show()
]]>
import dash
import dash_core_components as dcc
import dash_html_components as html
app = dash.Dash(__name__)
app.layout = html.Div([
html.H1('河北大数据中台'),
dcc.Graph(
id='example-graph',
figure={
'data': [
{'x': [1, 2, 3], 'y': [4, 1, 2], 'type': 'bar', 'name': 'Traffic'},
],
'layout': {
'title': '每日车流量'
}
}
)
])
if __name__ == '__main__':
app.run_server(debug=True)
]]>