锦中迎新管理系统

def clean_data(student_records):

cleaned_records = []

for record in student_records:

# 去除空格

name = record['name'].strip()

id = record['id'].strip()

major = record['major'].strip()

# 检查学号是否合法

if not id.isdigit() or len(id) != 10:

continue

# 添加到清理后的记录列表

cleaned_records.append({'name': name, 'id': id, 'major': major})

return cleaned_records

]]>

from pyspark.sql import SparkSession

# 初始化Spark会话

spark = SparkSession.builder.appName("StudentAnalysis").getOrCreate()

# 加载数据

student_df = spark.read.format("csv").option("header", "true").load("cleaned_student_data.csv")

# 统计各专业学生数量

major_count = student_df.groupBy("major").count()

# 显示结果

major_count.show()

]]>

@app.route('/checkin', methods=['POST'])

def check_in():

student_id = request.form['student_id']

# 查询数据库

student_info = db.query_student_by_id(student_id)

if student_info:

return render_template('checkin.html', info=student_info)

else:

return "未找到该学生信息"

]]>