jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-26 06:37:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use XML source instead of website (#2400)

Browse Source
This commit is contained in:
Fabian Affolter 2016-07-02 20:22:29 +02:00 committed by Paulus Schoutsen
parent a74cdc7b0d
commit a65f196d19
1 changed files with 29 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
homeassistant/components/sensor/swiss_hydrological_data.py
View File

@ -19,12 +19,14 @@ from homeassistant.util import Throttle
REQUIREMENTS = ['beautifulsoup4==4.4.1'] REQUIREMENTS = ['beautifulsoup4==4.4.1']
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
_RESOURCE = 'http://www.hydrodaten.admin.ch/en/' _RESOURCE = 'http://www.hydrodata.ch/xml/SMS.xml'
DEFAULT_NAME = 'Water temperature' DEFAULT_NAME = 'Water temperature'
CONF_STATION = 'station' CONF_STATION = 'station'
ICON = 'mdi:cup-water' ICON = 'mdi:cup-water'
ATTR_LOCATION = 'Location'
ATTR_UPDATE = 'Update'
ATTR_DISCHARGE = 'Discharge' ATTR_DISCHARGE = 'Discharge'
ATTR_WATERLEVEL = 'Level' ATTR_WATERLEVEL = 'Level'
ATTR_DISCHARGE_MEAN = 'Discharge mean' ATTR_DISCHARGE_MEAN = 'Discharge mean'
@ -42,9 +44,9 @@ PLATFORM_SCHEMA = vol.Schema({
HydroData = collections.namedtuple( HydroData = collections.namedtuple(
"HydrologicalData", "HydrologicalData",
['discharge', 'waterlevel', 'temperature', 'discharge_mean', ['waterlevel', 'waterlevel_max', 'waterlevel_mean', 'temperature',
'waterlevel_mean', 'temperature_mean', 'discharge_max', 'waterlevel_max', 'temperature_max', 'temperature_mean', 'discharge', 'discharge_max',
'temperature_max']) 'discharge_mean', 'location', 'update_time'])
# Return cached results if last scan was less then this time ago. # Return cached results if last scan was less then this time ago.
MIN_TIME_BETWEEN_UPDATES = timedelta(minutes=30) MIN_TIME_BETWEEN_UPDATES = timedelta(minutes=30)
@ -52,13 +54,16 @@ MIN_TIME_BETWEEN_UPDATES = timedelta(minutes=30)
def setup_platform(hass, config, add_devices, discovery_info=None): def setup_platform(hass, config, add_devices, discovery_info=None):
"""Setup the Swiss hydrological sensor.""" """Setup the Swiss hydrological sensor."""
from bs4 import BeautifulSoup
station = config.get(CONF_STATION) station = config.get(CONF_STATION)
name = config.get(CONF_NAME, DEFAULT_NAME) name = config.get(CONF_NAME, DEFAULT_NAME)
try: try:
response = requests.get('{}/{}.html'.format(_RESOURCE, station), response = requests.get(_RESOURCE, timeout=5)
timeout=5) if BeautifulSoup(
if not response.ok: response.content,
'html.parser').find(strnr='{}'.format(station)) is None:
_LOGGER.error('The given station does not seem to exist: %s', _LOGGER.error('The given station does not seem to exist: %s',
station) station)
return False return False
@ -94,13 +99,15 @@ class SwissHydrologicalDataSensor(Entity):
@property @property
def state(self): def state(self):
"""Return the state of the sensor.""" """Return the state of the sensor."""
return self._state return round(float(self._state), 1)
@property @property
def device_state_attributes(self): def device_state_attributes(self):
"""Return the state attributes.""" """Return the state attributes."""
if self.data.measurings is not None: if self.data.measurings is not None:
return { return {
ATTR_LOCATION: self.data.measurings.location,
ATTR_UPDATE: self.data.measurings.update_time,
ATTR_DISCHARGE: self.data.measurings.discharge, ATTR_DISCHARGE: self.data.measurings.discharge,
ATTR_WATERLEVEL: self.data.measurings.waterlevel, ATTR_WATERLEVEL: self.data.measurings.waterlevel,
ATTR_DISCHARGE_MEAN: self.data.measurings.discharge_mean, ATTR_DISCHARGE_MEAN: self.data.measurings.discharge_mean,
@ -135,28 +142,28 @@ class HydrologicalData(object):
@Throttle(MIN_TIME_BETWEEN_UPDATES) @Throttle(MIN_TIME_BETWEEN_UPDATES)
def update(self): def update(self):
"""Get the latest data from hydrodaten.admin.ch.""" """Get the latest data from hydrodata.ch."""
from bs4 import BeautifulSoup from bs4 import BeautifulSoup
try: try:
response = requests.get('{}/{}.html'.format(_RESOURCE, response = requests.get(_RESOURCE, timeout=5)
self.station),
timeout=5)
except requests.exceptions.ConnectionError: except requests.exceptions.ConnectionError:
_LOGGER.error('Unable to retrieve data') _LOGGER.error('Unable to retrieve data from %s', _RESOURCE)
response = None
try: try:
tables = BeautifulSoup(response.content, soup = BeautifulSoup(response.content, 'html.parser')
'html.parser').findChildren('table') # Water level: Typ="02", temperature: Typ="03", discharge: Typ="10"
rows = tables[0].findChildren(['th', 'tr']) type02, type03, type10 = [
soup.find(strnr='{}'.format(self.station), typ='{}'.format(i))
for i in ['02', '03', '10']]
details = [] details = []
for entry in [type02, type03, type10]:
for row in rows: details.append(entry.wert.string)
cells = row.findChildren('td') details.append(entry.find(typ="max24").string)
for cell in cells: details.append(entry.find(typ="m24").string)
details.append(cell.string) details.append(type03.find('name').string)
details.append(type03.find('zeit').string)
self.measurings = HydroData._make(details) self.measurings = HydroData._make(details)
except AttributeError: except AttributeError: