Openweather-for-Python/openweather_trig.py3 at master · ChrSchultz/Openweather-for-Python · GitHub

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
#!/usr/bin/python3
# -*- coding: utf8 -*-
# registers create alters and delets triggers and alerts by openweatermap.org
#   2017-23.07. Christoph Schultz

import urllib3
import json
import sys
import pprint
import argparse
import datetime


pool = urllib3.PoolManager()
ow_appid = "1f422f257ebc8ab249c166e634260f9d"
ow_lat = 52
ow_long = 10
ow_url = "http://api.openweathermap.org/data/3.0/triggers?appid=" + ow_appid
parser = argparse.ArgumentParser(description=' trigger tool for openweatermap by Christoph Schultz')
parser.add_argument('action')
args = parser.parse_args()
if args.action == "register":
    name = input("Trigger Ereignis:(temp,wind_speed,wind_dir, humidity, pressure, clouds)")
    begin = eval(input("Beginn:[vor|in,x ](Tagen)"))
    end = eval(input("Ende: [vor|in,x] (Tagen) Ende > Beginn"))
    if begin[0] == "vor":
        start_exp = "before"
    else:
        start_exp = "after"
    if end[0]== "vor":
        end_exp = "before"
    else:
        end_exp = "after"


    trig_start = begin[1]*24*60*60*1000
    trig_end = end[1]*24*60*60*1000
    #print(trig_start, trig_end)
    ow_post_data = {'time_period':{'start':{'expression':start_exp, 'amount':trig_start},
	'end':{'expression':end_exp, 'amount':trig_end}}, 'conditions':[{'name':name, 'expression':'$gt', 'amount':70}],
    'area':[{'type':'Point','coordinates':[ 52, 10 ]}]}
    print(ow_post_data)
    print(json.dumps(ow_post_data).encode('utf-8'))
    req = pool.request("POST", ow_url, body=json.dumps(ow_post_data).encode('utf-8'),
	headers={ 'Content-type': 'application/json'})
    res = req.data
    print(res)
 #---------------------------------------------------------------------
elif args.action == "alter":
    id = input("trigger_id:")
    c = eval(input(" Wieviele Alarme? (max 2)"))
    begin= eval(input("Beginn: [vor|in,x]Tagen"))
    end = eval(input("Ende: [vor|in,x] (Tagen) Ende > Beginn"))
    trig = eval(input("[name(str), Bedingung(grosser,kleiner,gleich), Wert(int)..:"))
    if begin[0] == "vor":
       start_exp = "before"
    else:
       start_exp = "after"
    if end [0]== "vor":
       end_exp = "before"
    else:
       end_exp = "after"
    if trig[0][1] == 'grosser':
       cond1 = '$gt'
    elif trig[0][1] == 'kleiner':
       cond1 = '$lt'
    else: cond1 = '$eq'
    if trig[1][1] == 'grosser':
       cond2 = '$gt'
    elif trig[1][1] == 'kleiner':
       cond2 = '$lt'
    else: cond2 = '$eq'

    trig_start = begin[1]*24*3600*1000
    trig_end = end[1]*24*60*60*1000
    ow_put_url = "http://api.openweathermap.org/data/3.0/triggers/" + id + "?appid=" + ow_appid
   # print(ow_put_url)
    ow_put_data = {'time_period':{'start':{'expression':start_exp, 'amount':trig_start},
	'end':{'expression':end_exp, 'amount':trig_end}}, 'contitions':[{'name': trig[0][0],
	'expression':cond1, 'amount':trig[0][2]},{'name':trig[1][0],'expression':cond2,'amount':trig[1][2]} ],
    'area':[{'type': 'Point','coordinates':[ow_lat, ow_long]}]}
    print(ow_put_data)
    req = pool.request("PUT", ow_put_url, body=json.dumps(ow_put_data).encode('utf-8'), headers={'Content-type': 'application/json'})
    res=req.data
    print(res)
  #-------------------------------------
if args.action == "delete":
     id = eval(input("id:"))
     ow_url = "http://api.openweathermap.org/data/3.0/triggers/" + id + "?appid=" + ow_appid
     req = pool.request("DELTE", ow_url)
     print(req.data)