MySQL&DBs

树莓派与postgre数据库

2018-09-16  本文已影响584人  meixia0731

家附近有个加油站,油价变化挺有意思,基本是某一天跳变到某一个最高值,之后每天降一点,然后保持最低价几天,最后又跳变到一个最高开始新的循环。
决定用树莓派把每日油价自动记录下来,方便油价最低的时候去加油,同时存到数据库里,顺便摸索一下python与数据库的连接。
初始版本是记录到一个text文件里,后来增加了与数据库的连接和insert操作。
系统版本:官方的raspbian
首先安装postgre

sudo apt-get update
sudo apt-get postgresql

看别人的记录还要装client,我没装好像也没问题
然后切换到数据库管理用户

sudo su postgres

创建一个pi用户,据说因为跟系统用户pi同名,会自动授权pi系统账户去使用pi数据库。

createuser pi -P --interactive

然后切换到pi账户去创建我需要的fuel_price DB。

createdb fuel_price

进入这个DB

psql fuel_check

创建我需要的table

create table fuel(current_date1 text primary key, price text);

检查下有没有创建成功

select * from fuel;

\q 退出数据库

\q

python读取网页需要的数据,同时存进去
提前安装python3的psycopg2

sudo apt-get install python3-Psycopg2
from urllib import request
import time
import psycopg2
req = request.Request('https://www.fuelcheck.nsw.gov.au/app/FuelPrice/ByLocation?latitude=-33.945423&longitude=151.246243&fuelType=U91&radius=4&suburb=MAROU$
req.add_header('User-Agent', 'Mozilla/6.0 (iPhone; CPU iPhone OS 8_0 like Mac OS X) AppleWebKit/536.26 (KHTML, like Gecko) Version/8.0 Mobile/10A5376e Safar$
port_num=[]
keywords='Coles Express Maroubra","Lat":-33.949944,"Long":151.240710,"Price":'
with request.urlopen(req) as f:
    port_num.append(f.read().decode('GBK'))
    # print(port_num)
    start=port_num[0].find(keywords)
    # print(start)
    port_num.append(port_num[0][(start+len(keywords)):(start+len(keywords)+5)])

print("今天的油价:",port_num[1])
print ("今日的日期:" + time.strftime("%d/%m/%Y"))
date1=str(time.strftime("%d%m%Y"))
today_recording=[time.strftime("%d/%m/%Y"),port_num[1]]
with open('/home/pi/spider/fuel/fuel_recording', 'a') as f:
    f.write(str(today_recording)+'\n')

conn = psycopg2.connect(dbname="fuel_price", user="pi",
        password="731731", host="127.0.0.1", port="5432")
cur = conn.cursor()
cur.execute("INSERT INTO fuel "
       "VALUES(%s,%s);"%(date1,port_num[1]))
conn.commit()
cur.close()
conn.close()

直接拿的之前一个爬小说更新程序改的,写的很烂但是能用。
这里在日期上折腾了好久,一直以为是定义的attribute data type 不对,价格可以存进去,但是日期死活写不进去,后来发现大家喜欢用01/01/2018 这种表示日期,但是斜杠这样不能当作value insert 进去,把斜杠去掉就好了。
最后把这个文件添加到定时任务里,每天早上跑一次,数据的处理还没想好,待续...

crontab -e
image.png

[参考了这篇](https://linux.cn/article-9056-1.html
[官方说明](http://www.postgresqltutorial.com/postgresql-python/

上一篇下一篇

猜你喜欢

热点阅读