-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathdht11_drive.py
147 lines (106 loc) · 5.28 KB
/
dht11_drive.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
# DHT11 湿度温度传感器 驱动
# 徐奥雯编写 XUAOWEN-ASSETS E-MAIL:[email protected] WECHAT:US-00000
# 使用方法： 接线 DHT11的三个引脚(如果是四个引脚NC不连接) VCC接5V GND接地 数据D接任意树莓派GPIO口
# 并将数据D接的树莓派GPIO口BCM编号设置为下面的pin
# 然后你可以直接运行本文件得到数值，也可以使用import dht11_drive导入模块
# 导入后使用 dht11_drive.dht11() 函数获取湿度与温度 返回值是一个元组
import RPi.GPIO as GPIO
import time
#############################################################
pin = 12 # 这里填写GPIO号（BCM引脚编号模式） 手动改变此行
#############################################################
GPIO.setmode(GPIO.BCM) # 设置使用BCM引脚编号模式
def main(pin):
GPIO.setup(pin,GPIO.OUT) # 設置引腳輸出
GPIO.output(pin,True) # 高电平
# 树莓派下拉19ms
GPIO.output(pin,False)
time.sleep(0.02)
#GPIO.output(pin,True)
GPIO.setup(pin,GPIO.IN) # 设置引腳输入
time_data_list = [] # 保存数据（高电平持续）时间的列表
pan_duan = 1 #判断数据是否正确
end_times = 0 # 数据是否接收完毕 决定是否结束大循环
start_time = 0 # 防止start_time未定义
end_time = 0 # 防止end_time未定义
while 1:
start_time_total = time.time() # 记录每次运行循环开始时间
if end_times == 1: # 数据接收完毕
break
while GPIO.input(pin) == 0: # 等待电平不为低
start_time = time.time() # 得到高电平开始时间
if (start_time - start_time_total) > 0.1 : # 判断循环时间过长 电平已经不再变化
end_times = 1
break
while GPIO.input(pin) == 1: # 等待电平不为高
end_time = time.time() # 得到高电平结束时间
if (end_time - start_time_total) > 0.1 : # 判断循环时间过长 电平已经不再变化
end_times = 1
break
time_data = end_time - start_time # 计算出高电平持续时间
time_data_list.append(time_data) # 高电平持续时间数据写入列表
# print(str(time_data)+', ', end='')
# print(time_data_list)
# print(len(time_data_list))
new_time_data_list = [] # 保存筛选过的时间
for i in range(len(time_data_list)):
if (time_data_list[i] > 1.9e-5 ) and (time_data_list[i] < 7.8e-5):
new_time_data_list.append(time_data_list[i])
#print(new_time_data_list)
#print(len(new_time_data_list))
if len(new_time_data_list) != 40:
pan_duan = 0 #判断数据是否正确
return 0, '接收到的数据位数不足，请重新尝试'
if pan_duan == 1: #判断数据是否正确
Binary_list = [] # 保存二进制数据
for i in new_time_data_list:
if i > 5.0e-5 :
Binary_list.append(1)
elif i < 5.0e-5 :
Binary_list.append(0)
if len(Binary_list) != 40 :
pan_duan = 0 #判断数据是否正确
return 0, '数据位数不足，请重新尝试'
#print(Binary_list)
#print(len(Binary_list))
if pan_duan == 1: #判断数据是否正确
# 转字符串格式
str_Binary_list = []
for i in Binary_list:
str_Binary_list.append(str(i))
if pan_duan == 1: #判断数据是否正确
# 分割数据 并合并成字符串
# 共40位数据 0-8为湿度整数 9-16为湿度小数 17-24为温度整数 25-32为湿度小数 33-40为校验和（前四个数据直接相加）
str_shidu_zhengshu = ''.join(str_Binary_list[0:8])
str_shidu_xiaoshu = ''.join(str_Binary_list[8:16])
str_wendu_zhengshu = ''.join(str_Binary_list[16:24])
str_wendu_xiaoshu = ''.join(str_Binary_list[24:32])
str_yanzheng = ''.join(str_Binary_list[32:40])
# 转换为十进制
int_shidu_zhengshu = int(str_shidu_zhengshu,2)
int_shidu_xiaoshu = int(str_shidu_xiaoshu,2)
int_wendu_zhengshu = int(str_wendu_zhengshu,2)
int_wendu_xiaoshu = int(str_wendu_xiaoshu,2)
int_yanzheng = int(str_yanzheng,2)
if int_yanzheng != (int_shidu_zhengshu + int_shidu_xiaoshu + int_wendu_zhengshu + int_wendu_xiaoshu):
pan_duan = 0 # 数据不正确
return 0, '校验和不匹配，请重新尝试'
if int_yanzheng == (int_shidu_zhengshu + int_shidu_xiaoshu + int_wendu_zhengshu + int_wendu_xiaoshu):
pan_duan = 1 # 数据正确
str_shidu = str(int_shidu_zhengshu) + '.' + str(int_shidu_xiaoshu)
str_wendu = str(int_wendu_zhengshu) + '.' + str(int_wendu_xiaoshu)
float_shidu = float(str_shidu)
float_wendu = float(str_wendu)
return 1, (float_shidu, float_wendu) # 返回 湿度 温度
def dht11(): # 循环五次
for i in range(5):
pan_duan_01, return_data = main(pin)
if pan_duan_01 == 1:
return return_data
time.sleep(0.5)
print('错误')
return return_data, return_data
if __name__ =='__main__':
shidu, wendu = dht11()
print('湿度为' + str(shidu) + '%')
print('温度为' + str(wendu) + '度')