怎样用Python检测智能电网中的电力窃漏行为？

import requests
import json
import pandas as pd

# 假设这是 API 接口
api_url = "https://api.smartgrid.com/usage"

# 模拟请求参数
params = {
    "start_date": "2023-01-01",
    "end_date": "2023-12-31"
}

try:
    response = requests.get(api_url, params=params)
    response.raise_for_status()  # 检查请求是否成功

    data = response.json()

    # 将 JSON 数据转换为 Pandas DataFrame
    df = pd.DataFrame(data)
    print(df.head())

except requests.exceptions.RequestException as e:
    print(f"API 请求失败: {e}")
except json.JSONDecodeError as e:
    print(f"JSON 解析失败: {e}")
except Exception as e:
    print(f"发生未知错误: {e}")

import pandas as pd
import numpy as np

# 假设 df 已经包含了用电数据
# 这里模拟一些数据
data = {'user_id': [1, 1, 1, 2, 2, 2, 3, 3, 3],
        'usage': [10, 12, 11, 5, 6, 7, 20, 22, 21]}
df = pd.DataFrame(data)


# 计算每个用户的平均用电量和标准差
user_stats = df.groupby('user_id')['usage'].agg(['mean', 'std'])

# 设置一个阈值，比如 3 倍标准差
threshold = 3

# 找出异常用户
anomalies = user_stats[user_stats['std'] > threshold * user_stats['mean']]

print("异常用户：")
print(anomalies)

from sklearn.ensemble import IsolationForest
import pandas as pd
import numpy as np

# 假设 df 已经包含了用电数据
# 这里模拟一些数据
data = {'user_id': [1, 1, 1, 2, 2, 2, 3, 3, 3],
        'usage': [10, 12, 11, 5, 6, 7, 20, 22, 21]}
df = pd.DataFrame(data)


# 使用 Isolation Forest 算法进行异常检测
model = IsolationForest(contamination='auto')
model.fit(df[['usage']])

# 预测每个用户的异常得分
df['anomaly_score'] = model.decision_function(df[['usage']])

# 标记异常用户
df['is_anomaly'] = model.predict(df[['usage']])

print(df)

# 假设已经检测到异常用户
# 可以发送警报邮件
import smtplib
from email.mime.text import MIMEText

def send_alert_email(user_id, usage):
    sender = "your_email@example.com"
    receiver = "admin_email@example.com"
    password = "your_password"

    message = MIMEText(f"用户 {user_id} 用电量异常：{usage}")
    message['Subject'] = "电力窃漏警报"
    message['From'] = sender
    message['To'] = receiver

    try:
        with smtplib.SMTP_SSL('smtp.example.com', 465) as server:
            server.login(sender, password)
            server.sendmail(sender, receiver, message.as_string())
        print("警报邮件已发送")
    except Exception as e:
        print(f"发送邮件失败: {e}")

# 假设用户 3 用电量异常
send_alert_email(3, 21)