def processWeatherDoc()

in noaa/_tools/process.py [0:0]


def processWeatherDoc(currentStationDoc):
    if "TMAX" in currentStationDoc:
        currentStationDoc["TMAX"] = float(currentStationDoc["TMAX"]) / 10.0
    if "TMIN" in currentStationDoc:
        currentStationDoc["TMIN"] = float(currentStationDoc["TMIN"]) / 10.0
    if "PRCP" in currentStationDoc:
        currentStationDoc["PRCP"] = float(currentStationDoc["PRCP"]) / 10.0
    if "AWND" in currentStationDoc:
        currentStationDoc["AWND"] = float(currentStationDoc["AWND"]) / 10.0
    if "EVAP" in currentStationDoc:
        currentStationDoc["EVAP"] = float(currentStationDoc["EVAP"]) / 10.0
    if "MDEV" in currentStationDoc:
        currentStationDoc["MDEV"] = float(currentStationDoc["MDEV"]) / 10.0
    if "MDPR" in currentStationDoc:
        currentStationDoc["MDPR"] = float(currentStationDoc["MDPR"]) / 10.0
    if "MDTN" in currentStationDoc:
        currentStationDoc["MDTN"] = float(currentStationDoc["MDTN"]) / 10.0
    if "MDTX" in currentStationDoc:
        currentStationDoc["MDTX"] = float(currentStationDoc["MDTX"]) / 10.0
    if "MNPN" in currentStationDoc:
        currentStationDoc["MNPN"] = float(currentStationDoc["MNPN"]) / 10.0
    if "MXPN" in currentStationDoc:
        currentStationDoc["MXPN"] = float(currentStationDoc["MXPN"]) / 10.0
    if "TAVG" in currentStationDoc:
        currentStationDoc["TAVG"] = float(currentStationDoc["TAVG"]) / 10.0
    if "THIC" in currentStationDoc:
        currentStationDoc["THIC"] = float(currentStationDoc["THIC"]) / 10.0
    if "TOBS" in currentStationDoc:
        currentStationDoc["TOBS"] = float(currentStationDoc["TOBS"]) / 10.0
    if "WESD" in currentStationDoc:
        currentStationDoc["WESD"] = float(currentStationDoc["WESD"]) / 10.0
    if "WESF" in currentStationDoc:
        currentStationDoc["WESF"] = float(currentStationDoc["WESF"]) / 10.0
    if "WSF1" in currentStationDoc:
        currentStationDoc["WSF1"] = float(currentStationDoc["WSF1"]) / 10.0
    if "WSF2" in currentStationDoc:
        currentStationDoc["WSF2"] = float(currentStationDoc["WSF2"]) / 10.0
    if "WSF5" in currentStationDoc:
        currentStationDoc["WSF5"] = float(currentStationDoc["WSF5"]) / 10.0
    if "WSFG" in currentStationDoc:
        currentStationDoc["WSFG"] = float(currentStationDoc["WSFG"]) / 10.0
    if "WSFI" in currentStationDoc:
        currentStationDoc["WSFI"] = float(currentStationDoc["WSFI"]) / 10.0
    if "WSFM" in currentStationDoc:
        currentStationDoc["WSFM"] = float(currentStationDoc["WSFM"]) / 10.0

    if "TMIN" in currentStationDoc and "TMAX" in currentStationDoc:
        if currentStationDoc["TMIN"] > currentStationDoc["TMAX"]:
            tmp = currentStationDoc["TMIN"]
            currentStationDoc["TMIN"] = currentStationDoc["TMAX"]
            currentStationDoc["TMAX"] = tmp
        currentStationDoc["TRANGE"] = {
            "gte": currentStationDoc["TMIN"],
            "lte": currentStationDoc["TMAX"],
        }
    if "MDTN" in currentStationDoc and "MDTX" in currentStationDoc:
        if currentStationDoc["MDTN"] > currentStationDoc["MDTX"]:
            tmp = currentStationDoc["MDTN"]
            currentStationDoc["MDTN"] = currentStationDoc["MDTX"]
            currentStationDoc["MDTX"] = tmp
        currentStationDoc["MDTRANGE"] = {
            "gte": currentStationDoc["MDTN"],
            "lte": currentStationDoc["MDTX"],
        }

    indexDoc = {
        "_op_type": "create",
        "_index": indexPrefix + "-" + str(currentStationDoc["date"].year),
        "_type": docType,
        "_id": currentStationDoc["date"].strftime("%Y-%m-%d") + "-" + currentStationDoc["station"]["id"],
        "_source": currentStationDoc,
    }
    return indexDoc