summaryrefslogtreecommitdiff
path: root/cron/handler.py
diff options
context:
space:
mode:
authorYuval Adam <_@yuv.al>2018-12-20 10:55:32 +0200
committerYuval Adam <_@yuv.al>2018-12-20 10:55:32 +0200
commit242541b8f8f892b5ad0820696f1093e84acc6152 (patch)
tree63fd9bbecd70d86e0025f5ed886978575565937a /cron/handler.py
parentbf650d0bc6f959b9a4fdb1ec6417bd32db067a68 (diff)
More WIPjordan
Diffstat (limited to 'cron/handler.py')
-rw-r--r--cron/handler.py41
1 files changed, 10 insertions, 31 deletions
diff --git a/cron/handler.py b/cron/handler.py
index 6342a4e..47d81bb 100644
--- a/cron/handler.py
+++ b/cron/handler.py
@@ -2,41 +2,21 @@ import boto3
import json
import urllib3
-import dateutil.parser as dp
-import xml.etree.ElementTree as ET
-
from datetime import datetime, timedelta
from io import StringIO
-
-BUCKET = 'imgs.geshem.space'
-
-http = urllib3.PoolManager()
-s3 = boto3.resource('s3')
-client = boto3.client('s3')
-yesterday = (datetime.utcnow().date() - timedelta(days=1)).strftime('%Y%m%d')
-
-def jordan_update():
- SOURCE_XML = 'http://212.35.78.67:8383/data/212JOC_rain_intensity.dpsri_dBR.xml'
- IMG_PREFIX = 'jordan/'
-
- res = http.request('GET', SOURCE_XML).data.decode('utf-8')
- root = ET.fromstring(res)
-
- try:
- latest_imgs = client.list_objects_v2(Bucket=BUCKET, Prefix=IMG_PREFIX, StartAfter=IMG_PREFIX + yesterday)['Contents']
- latest_keys = [i['Key'] for i in latest_imgs]
- except KeyError:
- latest_keys = []
-
-
-
def geshem_update():
MAPS_JSON = 'http://map.govmap.gov.il/rainradar/radar.json'
+ BUCKET = 'imgs.geshem.space'
IMG_PREFIX = 'imgs/'
+ http = urllib3.PoolManager()
+ s3 = boto3.resource('s3')
+ client = boto3.client('s3')
maps_json = json.loads(http.request('GET', MAPS_JSON).data.decode('utf-8'))
+
+ yesterday = (datetime.utcnow().date() - timedelta(days=1)).strftime('%Y%m%d')
response = ''
try:
@@ -85,16 +65,15 @@ def geshem_update():
def update(event, context):
res = geshem_update()
- jres = jordan_update()
body = {
- 'message': f'SUCCESS: {res}, {jres}',
- 'input': event
+ "message": "SUCCESS: \n" + res,
+ "input": event
}
response = {
- 'statusCode': 200,
- 'body': json.dumps(body)
+ "statusCode": 200,
+ "body": json.dumps(body)
}
return response