zoukankan      html  css  js  c++  java
  • python爬取疫情数据

    日期 开始时间 结束时间 中断时间 净时间 活动 备注
    3.10 3:40 5:45  20  105  查资料 查询Json与python
     3.10  6:10  7:00    50 安装软件  用于学习python
     3.11  10:15  11:20  10  55   编代码  学习python
     3:11  2:40  5:30  50  120  写代码  
     3.11  7:00  9:00  20  100  改代码  

    下面是爬取疫情数据代码

    import pymysql
    import re
    import json
    from pip._vendor import requests
    
    
    def create():
        db = pymysql.connect("localhost", "root", "123", "payiqing",charset='utf8')  # 连接数据库
    
        cursor = db.cursor()
        cursor.execute("DROP TABLE IF EXISTS info")
    
        sql = """CREATE TABLE info(
                Id INT PRIMARY KEY AUTO_INCREMENT,
                Date varCHAR(255),
                Province varchar(255),
                City varchar(255),
                Confirmed_num varchar(255),
                Yisi_num varchar(255),
                Cured_num varchar(255),
                Dead_num varchar(255),
                Code varchar(255))"""
    
        cursor.execute(sql)
    
        db.close()
    
    
    def insert(value):
        db = pymysql.connect("localhost", "root", "123", "payiqing",charset='utf8')
    
        cursor = db.cursor()
        sql = "INSERT INTO info(Date,Province,City,Confirmed_num,Yisi_num,Cured_num,Dead_num,Code) VALUES ( %s,%s,%s,%s,%s,%s,%s,%s)"
        try:
            cursor.execute(sql, value)
            db.commit()
            print('插入数据成功')
        except:
            db.rollback()
            print("插入数据失败")
        db.close()
    
    
    create()  # 创建表
    
    url='https://raw.githubusercontent.com/BlankerL/DXY-2019-nCoV-Data/master/json/DXYArea.json'
    response = requests.get(url)
    # 将响应信息进行json格式化
    versionInfo = response.text
    # print(versionInfo)#打印爬取到的数据
    # print("------------------------")#重要数据分割线↓
    
    #一个从文件加载,一个从内存加载#json.load(filename)#json.loads(string)
    jsonData = json.loads(versionInfo)
    
    #用于存储数据的集合
    dataSource = []
    provinceShortNameList = []
    confirmedCountList = []
    curedCount = []
    deadCountList = []
    #遍历对应的数据存入集合中
    for k in range(len(jsonData['results'])):
        if(jsonData['results'][k]['countryName'] == '中国'):
            provinceShortName = jsonData['results'][k]['provinceName']
            if("待明确地区" == provinceShortName):
                continue;
    
            for i in range(len(jsonData['results'][k]['cities'])):
                confirmnum=jsonData['results'][k]['cities'][i]['confirmedCount']
                yisi_num=jsonData['results'][k]['cities'][i]['suspectedCount']
                cured_num=jsonData['results'][k]['cities'][i]['curedCount']
                dead_num=jsonData['results'][k]['cities'][i]['deadCount']
                code=jsonData['results'][k]['cities'][i]['locationId']
                cityname=jsonData['results'][k]['cities'][i]['cityName']
                date='2020-3-10'
                insert((date,provinceShortName,cityname,confirmnum,yisi_num,cured_num,dead_num,code))

    爬取出的数据导入数据库表中:

  • 相关阅读:
    开通博客第一天
    Vue 打包配置productionSourceMap 的记录
    supervisorctl 的 简单记录
    mvn打包方式记录
    springboot日志配置,关于logback
    springboot集成swagger
    关于mapper文件的bean
    elasticsearch 连接、操作记录
    关于前后端分离文件上传的些许问题
    代码优化--策略模式的四种表现
  • 原文地址:https://www.cnblogs.com/tianwenjing123-456/p/12488430.html
Copyright © 2011-2022 走看看