# 引入所需要的全部包
from sklearn.model_selection import train_test_split
from sklearn.linear_model import LinearRegression
from sklearn.preprocessing import StandardScaler
import numpy as np
import matplotlib as mpl
import matplotlib.pyplot as plt
import pandas as pd
from pandas import DataFrame
import time
## 设置字符集,防止中文乱码
mpl.rcParams['font.sans-serif']=[u'simHei']
mpl.rcParams['axes.unicode_minus']=False
# 加载数据
# 日期、时间、有功功率、无功功率、电压、电流、厨房用电功率、洗衣服用电功率、热水器用电功率
path1='datas/household_power_consumption_1000.txt'
df = pd.read_csv(path1, sep=';', low_memory=False)#没有混合类型的时候可以通过low_memory=F调用更多内存,加快效率)
df.head() ## 获取前五行数据查看查看
Date Time Global_active_power Global_reactive_power Voltage Global_intensity Sub_metering_1 Sub_metering_2 Sub_metering_3
0 16/12/2006 17:24:00 4.216 0.418 234.84 18.4 0.0 1.0 17.0
1 16/12/2006 17:25:00 5.360 0.436 233.63 23.0 0.0 1.0 16.0
2 16/12/2006 17:26:00 5.374 0.498 233.29 23.0 0.0 2.0 17.0
3 16/12/2006 17:27:00 5.388 0.502 233.74 23.0 0.0 1.0 17.0
4 16/12/2006 17:28:00 3.666 0.528 235.68 15.8 0.0 1.0 17.0
# 查看格式信息
df.info()
<class 'pandas.core.frame.DataFrame'>
RangeIndex: 1000 entries, 0 to 999
Data columns (total 9 columns):
Date                     1000 non-null object
Time                     1000 non-null object
Global_active_power      1000 non-null float64
Global_reactive_power    1000 non-null float64
Voltage                  1000 non-null float64
Global_intensity         1000 non-null float64
Sub_metering_1           1000 non-null float64
Sub_metering_2           1000 non-null float64
Sub_metering_3           1000 non-null float64
dtypes: float64(7), object(2)
memory usage: 70.4+ KB
# 异常数据处理(异常数据过滤)
new_df = df.replace('?', np.nan)#替换非法字符为np.nan
datas = new_df.dropna(axis=0,how = 'any') # 只要有一个数据为空,就进行行删除操作
datas.describe().T#观察数据的多种统计指标
count mean std min 25% 50% 75% max
Global_active_power 1000.0 2.418772 1.239979 0.206 1.806 2.414 3.308 7.706
Global_reactive_power 1000.0 0.089232 0.088088 0.000 0.000 0.072 0.126 0.528
Voltage 1000.0 240.035790 4.084420 230.980 236.940 240.650 243.295 249.370
Global_intensity 1000.0 10.351000 5.122214 0.800 8.400 10.000 14.000 33.200
Sub_metering_1 1000.0 0.000000 0.000000 0.000 0.000 0.000 0.000 0.000
Sub_metering_2 1000.0 2.749000 8.104053 0.000 0.000 0.000 1.000 38.000
Sub_metering_3 1000.0 5.756000 8.066941 0.000 0.000 0.000 17.000 19.000
# 查看格式信息
df.info()
<class 'pandas.core.frame.DataFrame'>
RangeIndex: 1000 entries, 0 to 999
Data columns (total 9 columns):
Date                     1000 non-null object
Time                     1000 non-null object
Global_active_power      1000 non-null float64
Global_reactive_power    1000 non-null float64
Voltage                  1000 non-null float64
Global_intensity         1000 non-null float64
Sub_metering_1           1000 non-null float64
Sub_metering_2           1000 non-null float64
Sub_metering_3           1000 non-null float64
dtypes: float64(7), object(2)
memory usage: 70.4+ KB
## 创建一个时间函数格式化字符串
def date_format(dt):import timet = time.strptime(' '.join(dt), '%d/%m/%Y %H:%M:%S')return (t.tm_year, t.tm_mon, t.tm_mday, t.tm_hour, t.tm_min, t.tm_sec)
# 获取x和y变量, 并将时间转换为数值型连续变量
X = datas.iloc[:,0:2]
X = X.apply(lambda x: pd.Series(date_format(x)), axis=1)
Y = datas['Global_active_power']
X.head(2)
0 1 2 3 4 5
0 2006 12 16 17 24 0
1 2006 12 16 17 25 0
## 对数据集进行测试集合训练集划分
# X:特征矩阵(类型一般是DataFrame)
# Y:特征对应的Label标签(类型一般是Series)
# test_size: 对X/Y进行划分的时候,测试集合的数据占比, 是一个(0,1)之间的float类型的值
# random_state: 数据分割是基于随机器进行分割的,该参数给定随机数种子;给一个值(int类型)的作用就是保证每次分割所产生的数数据集是完全相同的
X_train,X_test,Y_train,Y_test = train_test_split(X, Y, test_size=0.2, random_state=0)
print(X_train.shape)
print(X_test.shape)
print(Y_train.shape)
(800, 6)
(200, 6)
(800,)
X_train.describe().T
count mean std min 25% 50% 75% max
0 800.0 2006.00000 0.000000 2006.0 2006.0 2006.0 2006.0 2006.0
1 800.0 12.00000 0.000000 12.0 12.0 12.0 12.0 12.0
2 800.0 16.59875 0.490458 16.0 16.0 17.0 17.0 17.0
3 800.0 10.75500 8.068386 0.0 4.0 8.0 19.0 23.0
4 800.0 29.72375 17.266517 0.0 15.0 30.0 45.0 59.0
5 800.0 0.00000 0.000000 0.0 0.0 0.0 0.0 0.0
## 数据标准化
# StandardScaler:将数据转换为标准差为1的数据集(有一个数据的映射)
# 如果一个API名字有fit,那么就有模型训练的含义
# 如果一个API名字中有transform, 那么就表示对数据具有转换的含义操作
# 如果一个API名字中有predict,那么就表示进行数据预测,会有一个预测结果输出
ss = StandardScaler()
X_train = ss.fit_transform(X_train) # 训练并转换
X_test = ss.transform(X_test) ## 直接使用在模型构建数据上进行一个数据标准化操作
pd.DataFrame(X_train).describe().T
count mean std min 25% 50% 75% max
0 800.0 0.000000e+00 0.000000 0.000000 0.000000 0.000000 0.000000 0.000000
1 800.0 0.000000e+00 0.000000 0.000000 0.000000 0.000000 0.000000 0.000000
2 800.0 2.196299e-15 1.000626 -1.221561 -1.221561 0.818625 0.818625 0.818625
3 800.0 -8.604228e-17 1.000626 -1.333814 -0.837742 -0.341670 1.022529 1.518601
4 800.0 3.691492e-17 1.000626 -1.722545 -0.853268 0.016009 0.885286 1.696611
5 800.0 0.000000e+00 0.000000 0.000000 0.000000 0.000000 0.000000 0.000000
## 模型训练
lr = LinearRegression()
lr.fit(X_train, Y_train) ## 训练模型
## 模型校验
y_predict = lr.predict(X_test) ## 预测结果print("训练R2:",lr.score(X_train, Y_train))
print("测试R2:",lr.score(X_test, Y_test))
mse = np.average((y_predict-Y_test)**2)
rmse = np.sqrt(mse)
print("rmse:",rmse)
训练R2: 0.24409311805909026
测试R2: 0.12551628513735846
rmse: 1.164092345973625
## 模型保存/持久化
# 在机器学习部署的时候,实际上其中一种方式就是将模型进行输出;另外一种方式就是直接将预测结果输出
# 模型输出一般是将模型输出到磁盘文件
from sklearn.externals import joblibjoblib.dump(ss, "data_ss.model") ## 将标准化模型保存
joblib.dump(lr, "data_lr.model") ## 将模型保存ss = joblib.load("data_ss.model") ## 加载模型
lr = joblib.load("data_lr.model") ## 加载模型
# 使用加载的模型进行预测
data1 = [[2006, 12, 17, 12, 25, 0]]
data1 = ss.transform(data1)
print(data1)
lr.predict(data1)
[[ 0.          0.          0.81862454  0.15440249 -0.27374978  0.        ]]array([1.16996393])
## 预测值和实际值画图比较
t=np.arange(len(X_test))
plt.figure(facecolor='w')#建一个画布,facecolor是背景色
plt.plot(t, Y_test, 'r-', linewidth=2, label='真实值')
plt.plot(t, y_predict, 'g-', linewidth=2, label='预测值')
plt.legend(loc = 'upper left')#显示图例,设置图例的位置
plt.title("线性回归预测时间和功率之间的关系", fontsize=20)
plt.grid(b=True)#加网格
plt.show()

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-StMpDQDu-1581861627931)(output_18_0.png)]

## 功率和电流之间的关系
X = datas.iloc[:,2:4]
Y2 = datas.iloc[:,5]## 数据分割
X2_train,X2_test,Y2_train,Y2_test = train_test_split(X, Y2, test_size=0.2, random_state=0)## 数据归一化
scaler2 = StandardScaler()
X2_train = scaler2.fit_transform(X2_train) # 训练并转换
X2_test = scaler2.transform(X2_test) ## 直接使用在模型构建数据上进行一个数据标准化操作 ## 模型训练
lr2 = LinearRegression()
lr2.fit(X2_train, Y2_train) ## 训练模型## 结果预测
Y2_predict = lr2.predict(X2_test)## 模型评估
print("电流预测准确率: ", lr2.score(X2_test,Y2_test))
print("电流参数:", lr2.coef_)## 绘制图表
#### 电流关系
t=np.arange(len(X2_test))
plt.figure(facecolor='w')
plt.plot(t, Y2_test, 'r-', linewidth=2, label=u'真实值')
plt.plot(t, Y2_predict, 'g-', linewidth=2, label=u'预测值')
plt.legend(loc = 'lower right')
plt.title(u"线性回归预测功率与电流之间的关系", fontsize=20)
plt.grid(b=True)
plt.show()
电流预测准确率:  0.9920420609708968
电流参数: [5.07744316 0.07191391]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-9AuelMOP-1581861627933)(output_19_1.png)]

十大经典算法_家庭用电预测:线性回归算法(时间与功率功率与电流之间的关系)相关推荐

  1. python 预测算法_通过机器学习的线性回归算法预测股票走势(用Python实现)

    本文转自博客园,作者为hsm_computer 原文链接:https://www.cnblogs.com/JavaArchitect/p/11717998.html在笔者的新书里,将通过股票案例讲述P ...

  2. pagerank数据集_机器学习十大经典算法-PageRank(附实践代码)

    Yo, yo, check it out. 保证看完不晕倒... 如果公式让你脑瓜疼,请忽略公式,或者忽略脑瓜. Kagging咖金:推荐系统之关联规则(附实践代码)​zhuanlan.zhihu.c ...

  3. 按复杂度有效性递减排序_十大经典排序算法:python源码实现,通俗深入讲解

    概述 提示:本文上万字,陆陆续续疏理知识点加测试代码,耗时近一个月.阅读时长40分钟左右. 本文将十大经典排序算法进行汇总,从源码实现.复杂度.稳定性进行分析,并对每种排序的特性进行点评.对典型算法, ...

  4. 冒泡和快速排序的时间复杂度_十大经典排序算法——快速排序

    目录 1.1.排序分类 1.2.排序的定义: 对一序列对象根据某个关键字进行排序. 1.3.术语说明 稳定:如果a原本在b前面,而a=b,排序之后a仍然在b的前面. 不稳定:如果a原本在b的前面,而a ...

  5. 【十大经典数据挖掘算法】Naïve Bayes

    [十大经典数据挖掘算法]系列 C4.5 K-Means SVM Apriori EM PageRank AdaBoost kNN Naïve Bayes CART 朴素贝叶斯(Naïve Bayes) ...

  6. 上手机器学习,从搞懂这十大经典算法开始

    上手机器学习,从搞懂这十大经典算法开始 翻译 | AI科技大本营(rgznai100) 参与 | 林椿眄 编辑 | 波波,Donna 在机器学习领域,"没有免费的午餐"是一个不变的 ...

  7. 教小学妹学算法:十大经典排序算法深度解析

    最近有一位小学妹 Coco 入坑了算法,结果上来就被几个排序算法给整懵逼了,各种排序眼花缭乱,也分不清什么时候该用什么排序了. 今天呢,就在这分享一下我给小学妹讲十大经典排序算法的过程. 好吧,那我们 ...

  8. 【十大经典数据挖掘算法】C4.5

    [十大经典数据挖掘算法]系列 C4.5 K-Means SVM Apriori EM PageRank AdaBoost kNN Naïve Bayes CART 1. 决策树模型与学习 决策树(de ...

  9. 数据结构十大经典排序算法--Python

    十大经典排序算法 (java实现看这个)https://program.blog.csdn.net/article/details/83785159 名词解释: 1.冒泡排序 2.选择排序 3.插入排 ...

  10. 十大经典算法总结(JavaScript描述)

    前言 读者自行尝试可以想看源码戳这,博主在github建了个库,欢迎star.读者可以Clone下来本地尝试.此博文配合源码体验更棒哦~~~ 个人博客:Damonare的个人博客 原文地址:十大经典算 ...

最新文章

  1. View requires API level 21 (current min is 15): Toolbar
  2. gpu的单位表示_GPU编程1--GPU中的基本概念
  3. qq空间网页版电脑_常用QQ软件,电脑C盘快满了,占用太多空间,如何快速清理?...
  4. .NET Core中Object Pool的简单使用
  5. fluent design_Fluent Design单选按钮,复选框,选择框,Java菜单
  6. (JAVA)CollectionDemo1
  7. c语言选择结构程序设计笔记,C语言选择结构程序设计.ppt
  8. Maven工程解决pom依赖红色波浪线报错
  9. ndarray、array、asarray的区别以及查看变量地址、is和==的区别
  10. linux常用命令清单
  11. ios linux远程控制软件,ios手机远程控制 ToDesk 1.0.9 iOS/iPad 版下载(远程控制软件)-520下载...
  12. 如何在CentOS 7上安装指定版本的PHP
  13. 10.17——10.24ACM笔记
  14. [教程]centos7.x 及centos8 硬盘安装法#免U盘#采坑记
  15. 游戏引擎剖析 (10) 人工智能和导航(路径发现)
  16. 第十四章聚类方法.14.3K均值聚类
  17. D-荧光素丨荧光素酶(Luciferase)常用底物
  18. ESP8266和双向可控硅在调速调光中的应用
  19. 使用ipmi进行服务器管理
  20. 37. 实战:Xpath+线程池实现抓取任意完整小说一千余节到本地txt文件/模板任意小说网站可套用(附源码)

热门文章

  1. 安卓奇葩问题之:返回按键监听,使Dialog不消失
  2. CMS 系统之 iframe 结构
  3. Reactor模式和NIO
  4. oracle的热备份和冷备份
  5. linux中文件查找命令
  6. PHP Cookbook读书笔记 – 第17章图形
  7. Ubuntu外观美化安装WPS
  8. tp5之允许跨域请求
  9. git 命令总结(转)
  10. 04-cmake语法-STREQUAL