用户行为实时分析新年优惠活动

import pandas as pd
from datetime import datetime

# 模拟实时数据流
def generate_data():
    while True:
        yield {
            'user_id': 'user_' + str(datetime.now().second),
            'action': 'click' if datetime.now().microsecond % 2 == 0 else 'view',
            'timestamp': datetime.now()
        }
        time.sleep(1)

# 实时数据处理和分析
def process_data():
    data_stream = generate_data()
    df = pd.DataFrame(columns=['user_id', 'action', 'timestamp'])
    
    for record in data_stream:
        new_row = pd.DataFrame([record])
        df = pd.concat([df, new_row], ignore_index=True)
        
        # 实时分析：计算每分钟的用户点击次数
        df['minute'] = df['timestamp'].dt.floor('T')
        click_counts = df[df['action'] == 'click'].groupby('minute').size()
        print(f"Minute {click_counts.index[-1]}: {click_counts.values[-1]} clicks")

if __name__ == "__main__":
    process_data()