Python开发---使用requests库调用Web API

# -*- coding:utf-8 -*-
import schedule
import requests
import json
from TOOLS import *
import time
from datetime import datetime,timedelta
eventUrl="上报事件API接口"

pcLogUrl='提交PC日志接口'

appLogUrl='提交APP日志接口'

waterEvent={
   "gridId": "",
    "eventTitle": "",
    "eventDesc": "",
    "eventLevel": "",
    "eventSource": "",
    "timeLimit": "",
    "longitude": "",
    "latitude": "",
    "pollutionKindId ":  "",
     
    "address": "",
 }


def sendEventHour(r):
    lastHour=dictStation[r['SiteId']]['lastHour']
     
    if((lastHour.get(r['Factor'])!=None) & (lastHour.get(r['Factor'])==r['RecordTime'])): 
        return 
     
    station=dictStation[r['SiteId']]
    waterEvent['gridId']=dictGrid[r['SiteId']]
    waterEvent['eventTitle']="%s%s小时数据超标报警"%(station['SiteName'],dictFactor22[r['Factor']])
    waterEvent['eventDesc']="时间:%s,监测值:%s,目标值:%s"%(r['RecordTime'],r['Value'],r['Target'])
    waterEvent['longitude']=station['Longitude']
    waterEvent['latitude']=station['Latitude']
    waterEvent['address']=station['SiteName']
      
    print(waterEvent)
    dictStation[r['SiteId']]['lastHour'][r['Factor']]=r['RecordTime']
    r=requests.post(eventUrl,{'waterEvent':json.dumps(waterEvent)})
    print(r.status_code)
def sendEventMinute(r):
    lastMinute=dictStation[r['SiteId']]['lastMinute']
    if((lastMinute.get(r['Factor'])!=None) & (lastMinute.get(r['Factor'])==r['RecordTime'])):    
        return 
            
    station=dictStation[r['SiteId']]
    waterEvent['gridId']=dictGrid[r['SiteId']]
    waterEvent['eventTitle']="%s%s分钟数据超标报警"%(station['SiteName'],dictFactor22[r['Factor']])
    waterEvent['eventDesc']="时间:%s,监测值:%s,目标值:%s"%(r['RecordTime'],r['Value'],r['Target'])
    waterEvent['longitude']=station['Longitude']
    waterEvent['latitude']=station['Latitude']
    waterEvent['address']=station['SiteName']
    print(waterEvent)
    dictStation[r['SiteId']]['lastMinute'][r['Factor']]=r['RecordTime']
    r=requests.post(eventUrl,{'waterEvent':json.dumps(waterEvent)})
    print(r.status_code)


def uploadLogs(data):
    logPath="data.txt"

    f=open(logPath,'r')
    idsDict=json.load(f)
    f.close()
    
    

    pcLogs=filter(lambda x:int(x['SourceType'])==1 and x['USERNAME']!=''and x['IDS'] not in idsDict['pc'],data)
    
    pcLogs=list(pcLogs)
    print(len(pcLogs))
    pcLogIds=list(map(lambda x:x['IDS'],pcLogs))

    appLogs=filter(lambda x:int(x['SourceType'])==0 and x['USERNAME']!='' and x['IDS'] not in idsDict['app'],data)
    appLogs=list(appLogs)
    print(len(appLogs))
    appLogIds=list(map(lambda x:x['IDS'],appLogs))
    
    if len(pcLogs)>0:
        pcLogs=map(lambda x:{
	"userId": x["USERNAME"],
	"appId": "your appId",
	"loginName": x["USERNAME"],
	"actionTime": x["OPERATETIME"].replace("T"," "),
	"action": x["SHORTNAME"]+'---'+x["CONTENTS"],
	"ip": x["COMPUTERIP"],
	"remark": "无"
        },pcLogs)
        pcLogs=list(pcLogs)
        r=requests.post(pcLogUrl,json=pcLogs)
        print(r.status_code)
        print(r.text)
        if(r.status_code==200):
            print(r.url)
            print(r.text)
            idsDict['pc']+=pcLogIds
            f=open(logPath,'w')
            json.dump(idsDict,f)
            f.close()

    if len(appLogs)>0:
        
        appLogs=map(lambda x:{
	"userId": x["USERNAME"],
	 
	"loginName": x["USERNAME"],
	"actionTime": x["OPERATETIME"].replace("T"," "),
	"action": x["SHORTNAME"]+'---'+x["CONTENTS"],
	"imei": x["COMPUTERIP"],
        "appPackage": "water",
	"remark": "无"
        },appLogs)
        appLogs=list(appLogs)
        r=requests.post(appLogUrl,json=appLogs)
        print(r.status_code)
        print(r.text)
        if(r.status_code==200):
            print(r.url)
            print(r.text)
            idsDict['app']+=appLogIds
            f=open(logPath,'w')
            json.dump(idsDict,f)
            f.close()
            
def hourJob():
    #print(dictStation)
    try:
        hourData=getHourAlarm()
    
        for i in hourData:
            sendEventHour(i)
    except:
        pass
        
def minuteJob():
    #print(dictStation)
    minuteData=getMinuteAlarm()
    for i in minuteData:
        sendEventMinute(i)
def logJob():
    today=datetime.now()
    print(today.strftime('%Y-%m-%d'))
    yesterday=today-timedelta(days=1)
    tomorrow=today+timedelta(days=1)
    try:
        data=getLogs(yesterday.strftime('%Y-%m-%d'),tomorrow.strftime('%Y-%m-%d'))
        print(len(data))
        uploadLogs(data)
    except:
        pass
    

if __name__=='__main__':
     
    global dictStation
    global dictTarget
    dictStation=getStation()
     
    dictTarget=getTarget()
    schedule.every(3).hours.do(hourJob)
    schedule.every(10).minutes.do(logJob)
    #schedule.every(10).minutes.do(minuteJob)
    
    while True:
        schedule.run_pending()