104 lines
3.1 KiB
Python
104 lines
3.1 KiB
Python
import requests
|
|
import gzip
|
|
import os
|
|
import shutil
|
|
import xml.dom.minidom
|
|
import logging,coloredlogs
|
|
import aiohttp, aiofiles, asyncio
|
|
|
|
import py2Lib.bit
|
|
import util.machineProductCfg as MPC
|
|
import records.lfRecord as LFR
|
|
|
|
l = logging.getLogger(__name__)
|
|
coloredlogs.install()
|
|
|
|
locationIds = []
|
|
zipCodes = []
|
|
airports = []
|
|
|
|
for i in MPC.getPrimaryLocations():
|
|
locationIds.append(LFR.getCoopId(i))
|
|
zipCodes.append(LFR.getZip(i))
|
|
|
|
airports = MPC.getAirportCodes()
|
|
l.debug(airports)
|
|
|
|
# Open the config file and make it accessible via "cfg"
|
|
import json
|
|
with open("config.json", "r") as file:
|
|
cfg = json.load(file)
|
|
|
|
apiKey = cfg["twcApiKey"]
|
|
|
|
async def getData(airport):
|
|
url = f"https://api.weather.com/v1/airportcode/{airport}/airport/delays.xml?language=en-US&apiKey={apiKey}"
|
|
data = ""
|
|
|
|
async with aiohttp.ClientSession() as s:
|
|
async with s.get(url) as r:
|
|
data = await r.text()
|
|
|
|
newData = data[48:-11].replace('¿', '-')
|
|
|
|
# Write to i2doc file
|
|
i2Doc = f'<AirportDelays id="000000000" locationKey="{airport}" isWxScan="0">' + '' + newData + f'<clientKey>{airport}</clientKey></AirportDelays>'
|
|
|
|
async with aiofiles.open("./.temp/AirportDelays.i2m", 'a') as f:
|
|
await f.write(i2Doc)
|
|
await f.close()
|
|
|
|
async def writeData():
|
|
loop = asyncio.get_running_loop()
|
|
useData = False
|
|
airportsWithDelays = []
|
|
|
|
for x in airports:
|
|
async with aiohttp.ClientSession() as s:
|
|
async with s.get(f"https://api.weather.com/v1/airportcode/{x}/airport/delays.xml?language=en-US&apiKey={apiKey}") as r:
|
|
if r.status != 200:
|
|
l.debug(f"No delay for {x} found, skipping..")
|
|
else:
|
|
airportsWithDelays.append(x)
|
|
useData = True
|
|
|
|
if (useData):
|
|
l.info("Writing an AirportDelays record.")
|
|
header = '<Data type="AirportDelays">'
|
|
footer = "</Data>"
|
|
|
|
async with aiofiles.open("./.temp/AirportDelays.i2m", 'w') as doc:
|
|
await doc.write(header)
|
|
|
|
for x in airportsWithDelays:
|
|
await getData(x)
|
|
|
|
async with aiofiles.open("./.temp/AirportDelays.i2m", 'a') as end:
|
|
await end.write(footer)
|
|
|
|
dom = xml.dom.minidom.parse("./.temp/AirportDelays.i2m")
|
|
prettyXml = dom.toprettyxml(indent=" ")
|
|
|
|
async with aiofiles.open("./.temp/AirportDelays.i2m", 'w') as g:
|
|
await g.write(prettyXml)
|
|
await g.close()
|
|
|
|
files = []
|
|
commands = []
|
|
with open("./.temp/AirportDelays.i2m", 'rb') as f_in:
|
|
with gzip.open("./.temp/AirportDelays.gz", 'wb') as f_out:
|
|
shutil.copyfileobj(f_in, f_out)
|
|
|
|
gZipFile = "./.temp/AirportDelays.gz"
|
|
|
|
files.append(gZipFile)
|
|
comand = commands.append('<MSG><Exec workRequest="storeData(File={0},QGROUP=__AirportDelays__,Feed=AirportDelays)" /><GzipCompressedMsg fname="AirportDelays" /></MSG>')
|
|
numFiles = len(files)
|
|
|
|
bit.sendFile(files, commands, numFiles, 0)
|
|
|
|
os.remove("./.temp/AirportDelays.i2m")
|
|
os.remove("./.temp/AirportDelays.gz")
|
|
else:
|
|
l.info("No airport delays found.")
|