Cliff:
I got aprs-is posts working, after a few bumps along the way (like not enforcing two digit humidity, and seeing packets that had one-digit humidity being seen by the system, but invalid for wx and considered position? (same issue when wind-dir dropped under 100 and was no longer three digits).
I am offline right now as I swap an rpi in place of the laptop running the python posting program.? The posting part of the code is below.? The python prog gets 1-minute updates from my rooftop sensor gizmo (rain and wind sensors from sparkfun, bme280 for PHT, shtc3 for HT, tmp100 for a third T), formats and posts every six minutes.? I trust the shtc3 humidity more than the bme (which, to be fair, I have not conditioned).? I am new to python, so are probably cleaner ways to code it, but fwiw:
gil
-------------
??? def process_WX1_mssg(self, wxdata):
???????
??????? # --- configure settings as needed:
??????? import? settings??? as z
??????? import? logging
??????? from??? datetime??? import datetime
??????? import? requests
??????? #from??? http.client import HTTPConnection
??????? from??? Adafruit_IO import Client, Feed
??????? from??? surlee_std? import SurAccumulator
??????? # save wx params (leave udhm param as string and convert other params to ints):
??????? utc_day_hour_minute = wxdata[3]
??????? try:
??????????? s1_temperatureF = int(wxdata[4]) / 10
??????????? s1_pressureMBARx10 = int(wxdata[5])
??????????? s1_pressureINHG = int(wxdata[6]) / 100
??????????? s1_humidity_PCT = int(wxdata[7]) / 10
??????????? s2_temperatureF = int(wxdata[8]) / 10
??????????? s2_humidity_PCT = int(wxdata[9]) / 10
??????????? s3_temperatureF = int(wxdata[10]) / 10
??????????? rain_INx1000 = int(wxdata[11])
??????????? wind_MPH = int(wxdata[12]) / 10
??????????? gust_MPH = int(wxdata[13]) / 10
??????????? wind_dir_DEG = int(wxdata[14])
??????? except (ValueError, TypeError, OverflowError):
??????????? raise UserWarning('process_mssg error: Bad Parameter')
??????? if z.DEBUG_PROCESS_MSSG_1MIN:
??????????? self.main_logger.debug('\n??? utc_day_hour_minute: ' + utc_day_hour_minute
?????????????? + ', s1_tempF: ' + str(s1_temperatureF) + ', s1_presMBARx10: ' + str(s1_pressureMBARx10)
?????????????? + ', s1_presINHG: ' + str(s1_pressureINHG) + ', s1_hum_PCT: ' + str(s1_humidity_PCT)
?????????????? + ', s2_tempF: ' + str(s2_temperatureF)? + ', s2_hum_PCT: ' + str(s2_humidity_PCT)
?????????????? + ', s3_tempF: ' + str(s3_temperatureF)
?????????????? + ', rain_INx1000: ' + str(rain_INx1000) + ', wind_MPH: ' + str(wind_MPH)
?????????????? + ', gust_MPH: ' + str(gust_MPH) + ', wind_dir_DEG: ' + str(wind_dir_DEG) + '\n'
??????????? )
??????? # --- update previous-hour rain accumulator:
??????? self.rain_prev_hour_INx1000.addnew(rain_INx1000)
??????? self.rain_prev_24hour_INx1000.addnew(rain_INx1000)
??????? # ========== this happens every 6 minutes for WX posting:
??????? self.minute_cnt -= 1
??????? if self.minute_cnt <= 0:
??????????? self.minute_cnt = 6
??????????? # --- derived data:
??????????? dew_ptF = self.dewpoint_approximation(s3_temperatureF, s2_humidity_PCT)???????????????
??????????? rain_prev_hour_INx100 = self.rain_prev_hour_INx1000.current() / 10???
??????????? rain_prev_hour_IN = self.rain_prev_hour_INx1000.current() / 1000???????????
??????????? rain_prev_24hour_INx100 = self.rain_prev_24hour_INx1000.current() / 10???
??????????? rain_prev_24hour_IN = self.rain_prev_24hour_INx1000.current() / 1000???????????
???????????
??????????? # ===== send to aprs-is:
??????????? if z.POST_APRS_IS:???????????????????
??????????????? if z.DEBUG_POSTS:
??????????????????? self.main_logger.debug('(post to aprs-is)')
???????????????????
??????????????? # for aprs RH, 100% reported as 0:
??????????????? aprs_hum = s2_humidity_PCT
??????????????? if aprs_hum >= 100:
??????????????????? aprs_hum = 0
??????????????? # (UTC DayHoursMinutes required for aprs-is but only seen in raw packets)
??????????????? p = z.APRS_USER + '>APRS,TCPIP*:@'
??????????????? # hard-coded lat/lon are deg and decimal minutes
??????????????? p += f'{utc_day_hour_minute}z3335.77N/11154.07W_'
??????????????? p += f'{wind_dir_DEG:03.0f}/{wind_MPH:03.0f}g{gust_MPH:03.0f}'
??????????????? p += f't{s3_temperatureF:-03.0f}r{rain_prev_hour_INx100:03.0f}'
??????????????? p += f'p{rain_prev_24hour_INx100:03.0f}P000'
??????????????? p += f'h{aprs_hum:02.0f}b{s1_pressureMBARx10:05.0f}L001SurleeWX\r\n'
??????????????? if z.DEBUG_POST_DETAIL:
??????????????????? print(p)
??????????????? self.update_aprs(p)
???????????????
?????????
??????????? # ===== send to weather-underground:
??????????? if z.POST_WEATHER_UNDERGROUND:
??????????????? if z.DEBUG_POSTS:
??????????????????? self.main_logger.debug('(post to weather-underground)')
???????????????????
??????????????? # (use dateutc=now since timestamping is done in wunderground)
??????????????? p = ''
??????????????? p += f'?ID={z.WUND_ID}&PASSWORD={z.WUND_PW}&dateutc=now'
??????????????? p += f'&tempf={s3_temperatureF:.1f}'
??????????????? p += f'&temp2f={s2_temperatureF:.1f}'
??????????????? p += f'&temp3f={s1_temperatureF:.1f}'
??????????????? p += f'&humidity={s2_humidity_PCT:.1f}'
??????????????? p += f'&dewptf={dew_ptF:.1f}'
??????????????? p += f'&indoorhumidity={s1_humidity_PCT:.1f}'
??????????????? p += f'&baromin={s1_pressureINHG:.2f}'
??????????????? p += f'&rainin={rain_prev_hour_IN:.2f}'
??????????????? p += f'&dailyrainin={rain_prev_24hour_IN:.2f}'
??????????????? #p += f'&solarradiation={xxx:.2f}'
??????????????? #p += f'&UV={xxx:.2f}'
??????????????? p += f'&windspeedmph={wind_MPH:.1f}'
??????????????? p += f'&windgustmph={gust_MPH:.1f}'
??????????????? p += f'&winddir={wind_dir_DEG:.0f}'
??????????????? p += '&realtime=1&rtfreq=10&action=updateraw\r\n'
??????????????? if z.DEBUG_POST_DETAIL:
??????????????????? print(p)
??????????????? requests.get(p)
???????????
???????????
??????????? # ===== send to pws-weather:
??????????? if z.POST_PWS_WEATHER:
??????????????? if z.DEBUG_POSTS:
??????????????????? self.main_logger.debug('(post to pws-weather)')
???????????????????
??????????????? # (utc date/time required, eg: &dateutc=2021-03-22+20:01:00)
??????????????? utcdt = datetime.nowutc().isoformat(timespec='seconds')
??????????????? utcdt = utcdt.replace('T' , '+')
??????????????? p = ''
??????????????? p += f'?ID={z.PWS_ID}&PASSWORD={z.PWS_PW}&dateutc={utcdt}'
??????????????? p += f'&tempf={s3_temperatureF:.1f}'
??????????????? p += f'&humidity={s2_humidity_PCT:.1f}'
??????????????? p += f'&dewptf={dew_ptF:.1f}'
??????????????? p += f'&baromin={s1_pressureINHG:.2f}'
??????????????? p += f'&rainin={rain_prev_hour_IN:.2f}'
??????????????? p += f'&dailyrainin={rain_prev_24hour_IN:.2f}'
??????????????? #p += f'&solarradiation={xxx:.2f}'
??????????????? #p += f'&UV={xxx:.2f}'
??????????????? p += f'&windspeedmph={wind_MPH:.1f}'
??????????????? p += f'&windgustmph={gust_MPH:.1f}'
??????????????? p += f'&winddir={wind_dir_DEG:.0f}'
??????????????? p += '&softwaretype=SurleeWX&action=updateraw\r\n'
??????????????? if z.DEBUG_POST_DETAIL:
??????????????????? print(p)
??????????????? requests.get(p)
??????????? # ===== send to adafruit-io:
??????????? if z.POST_ADAFRUITIO:
??????????????? if z.DEBUG_POSTS:
??????????????????? self.main_logger.debug('(post to adafruit-io)')
???????????????????
??????????????? # (timestamping is done in adafruit-io)
??????????????? temperature = '%.2f'%(temperatureF)
??????????????? pressure = '%.2f'%(pressureINHG)
??????????????? humidity = '%.2f'%(humidity)
??????????????? aio.send(temperature_feed.key, str(temperature))
??????????????? aio.send(pressure_feed.key, str(pressure))
??????????????? aio.send(humidity_feed.key, str(humidity))
??????? return
??? def update_aprs(self, ptxt):
??????? ''' update aprs.is, if available: '''
???????
??????? # --- configure settings as needed:
??????? import? settings??? as z
??????? import? socket
??????? with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
??????????? #s.settimeout(5)
??????????? try:
??????????????? s.connect(("noam.aprs2.net", 14580))
??????????????? ltxt = 'user ' + z.APRS_USER + ' pass ' + z.APRS_PW + ' vers SurleeWX 21.0.0\r\n'
??????????????? login = ltxt.encode('utf-8')
??????????????? wxdat = ptxt.encode('utf-8')
??????????????? s.sendall(login)
??????????????? s.sendall(wxdat)
??????????? except socket.error as msg:
??????????????? print (msg)
??????? return
Bill WA4OPQ
Cliff Sojourner K6CLS