Compare commits
26 Commits
feature/va
...
d20b48e6b1
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d20b48e6b1 | ||
|
|
d1438f9a0b | ||
|
|
c1b7b16251 | ||
|
|
e6c2644ea5 | ||
|
|
fc5f6e7c93 | ||
|
|
fa052cdfc9 | ||
|
|
f6f799e85f | ||
|
|
a44308a4e1 | ||
|
|
dd5bb2916b | ||
|
|
67bb1e49ef | ||
|
|
aaea39657e | ||
|
|
81c19b552d | ||
|
|
0d609ade9a | ||
|
|
2b453f4b5e | ||
|
|
62904f4c09 | ||
|
|
35d5232d8e | ||
|
|
1c3b0ae0b5 | ||
|
|
d2e8f77725 | ||
|
|
92e99e03ef | ||
|
|
903a512f99 | ||
|
|
f385ee3a5a | ||
|
|
573f91e2f9 | ||
|
|
025a6475dd | ||
|
|
216775e68f | ||
|
|
403efb937b | ||
|
|
559a463140 |
10
.github/workflows/python-app.yml
vendored
10
.github/workflows/python-app.yml
vendored
@@ -50,3 +50,13 @@ jobs:
|
||||
- name: Test with pytest
|
||||
run: |
|
||||
poetry run pytest
|
||||
|
||||
validate:
|
||||
runs-on: "ubuntu-latest"
|
||||
steps:
|
||||
- uses: "actions/checkout@v2"
|
||||
- name: HACS validation
|
||||
uses: "hacs/action@main"
|
||||
with:
|
||||
category: "integration"
|
||||
ignore: brands wheels
|
||||
|
||||
24
README.md
24
README.md
@@ -2,7 +2,8 @@
|
||||
|
||||
## Adding to your dashboard
|
||||
|
||||
You can add an overview of the current infection numbers to your dashboard using the [multiple-entity-row](https://github.com/benct/lovelace-multiple-entity-row) card:
|
||||
You can add an overview of the current infection and vaccination numbers to your dashboard
|
||||
using the [multiple-entity-row](https://github.com/benct/lovelace-multiple-entity-row) card:
|
||||
|
||||
```yaml
|
||||
type: entities
|
||||
@@ -24,4 +25,25 @@ entities:
|
||||
secondary_info:
|
||||
attribute: incidence
|
||||
unit: cases/100k
|
||||
- type: custom:multiple-entity-row
|
||||
entity: sensor.covid_19_vaccinations_augsburg
|
||||
entities:
|
||||
- attribute: ratio_vaccinated_once
|
||||
name: Once
|
||||
format: precision1
|
||||
unit: '%'
|
||||
- attribute: ratio_vaccinated_full
|
||||
name: Fully
|
||||
format: precision1
|
||||
unit: '%'
|
||||
- attribute: ratio_vaccinated_total
|
||||
name: Total
|
||||
format: precision1
|
||||
unit: '%'
|
||||
show_state: false
|
||||
icon: mdi:needle
|
||||
name: COVID-19 Vaccinations
|
||||
secondary_info:
|
||||
attribute: date
|
||||
format: date
|
||||
```
|
||||
|
||||
@@ -12,11 +12,11 @@ if TYPE_CHECKING:
|
||||
from homeassistant.core import HomeAssistant
|
||||
|
||||
from .const import DOMAIN
|
||||
from .crawler import CovidCrawler, IncidenceData
|
||||
from .crawler import CovidCrawler
|
||||
|
||||
_LOGGER = logging.getLogger(__name__)
|
||||
|
||||
__version__ = "0.1.0"
|
||||
__version__ = "1.2.2"
|
||||
|
||||
PLATFORMS = ["sensor"]
|
||||
|
||||
@@ -67,9 +67,12 @@ async def get_coordinator(hass: HomeAssistant):
|
||||
if DOMAIN in hass.data:
|
||||
return hass.data[DOMAIN]
|
||||
|
||||
async def async_get_data() -> IncidenceData:
|
||||
async def async_get_data() -> dict:
|
||||
crawler = CovidCrawler(hass)
|
||||
return await crawler.crawl_incidence()
|
||||
return {
|
||||
"incidence": await crawler.crawl_incidence(),
|
||||
"vaccination": await crawler.crawl_vaccination(),
|
||||
}
|
||||
|
||||
hass.data[DOMAIN] = DataUpdateCoordinator(
|
||||
hass,
|
||||
|
||||
@@ -59,9 +59,12 @@ class VaccinationData:
|
||||
total_vaccinations: int = 0
|
||||
num_vaccinated_once: int = 0
|
||||
num_vaccinated_full: int = 0
|
||||
num_vaccinated_booster: int = 0
|
||||
|
||||
ratio_vaccinated_once: float = 0.0
|
||||
ratio_vaccinated_full: float = 0.0
|
||||
ratio_vaccinated_total: float = 0.0
|
||||
ratio_vaccinated_booster: float = 0.0
|
||||
|
||||
|
||||
class CovidCrawlerBase(ABC):
|
||||
@@ -106,11 +109,11 @@ class CovidCrawler(CovidCrawlerBase):
|
||||
)
|
||||
soup = await self._fetch(url)
|
||||
|
||||
match = soup.find(class_="frame--type-textpic")
|
||||
text = match.p.text
|
||||
match = soup.find(id="c1075340")
|
||||
text = match.text.strip()
|
||||
_log.debug(f"Infection data text: {text}")
|
||||
|
||||
matches = re.search(r"(\d+,\d+)\sNeuinfektion", text)
|
||||
matches = re.search(r"(\d+(,\d+)?)\sNeuinfektion", text)
|
||||
if not matches:
|
||||
raise ValueError(
|
||||
f"Could not extract incidence from scraped web page, {text=}"
|
||||
@@ -119,18 +122,15 @@ class CovidCrawler(CovidCrawlerBase):
|
||||
incidence = parse_num(matches.group(1), t=float)
|
||||
_log.debug(f"Parsed incidence: {incidence}")
|
||||
|
||||
text = match.h2.text
|
||||
matches = re.search(r"\((\d+)\. (\w+).*\)", text)
|
||||
match = soup.find(id="c1052517")
|
||||
text = match.text.strip()
|
||||
matches = re.search(r"Stand: (\d+)\. (\w+) (\d{4})", text)
|
||||
if not matches:
|
||||
raise ValueError(f"Could not extract date from scraped web page, {text=}")
|
||||
|
||||
date = parse_date(matches.group(1), matches.group(2))
|
||||
date = parse_date(matches.group(1), matches.group(2), matches.group(3))
|
||||
_log.debug(f"Parsed date: {date}")
|
||||
|
||||
match = match.find_next_sibling(class_="frame--type-textpic")
|
||||
text = match.text
|
||||
_log.debug(f"Infection counts text: {text}")
|
||||
|
||||
regexes = [
|
||||
r"Insgesamt: (?P<total_cases>[0-9.]+)",
|
||||
r"genesen: (?P<num_recovered>[0-9.]+)",
|
||||
@@ -167,9 +167,9 @@ class CovidCrawler(CovidCrawlerBase):
|
||||
result = soup.find(id=container_id)
|
||||
text = re.sub(r"\s+", " ", result.text)
|
||||
regexes = [
|
||||
r"(?P<total_vaccinations>\d+[.]\d+) Impfdosen",
|
||||
r"Weitere (?P<num_vaccinated_once>\d+[.]\d+) Personen haben die Erstimpfung erhalten",
|
||||
r"(?P<num_vaccinated_full>\d+[.]\d+) Personen sind bereits vollständig geimpft",
|
||||
r"(?P<total_vaccinations>\d+([.]\d+)?) Personen in Augsburg",
|
||||
r"(?P<num_vaccinated_full>\d+([.]\d+)?) Personen in Augsburg",
|
||||
r"(?P<num_vaccinated_booster>\d+([.]\d+)?) Personen, also",
|
||||
]
|
||||
values = {}
|
||||
for r in regexes:
|
||||
@@ -187,15 +187,24 @@ class CovidCrawler(CovidCrawlerBase):
|
||||
if not matches:
|
||||
raise ValueError(f"Could not extract date from scraped web page, {text=}")
|
||||
|
||||
values["num_vaccinated_once"] = (
|
||||
values["total_vaccinations"] - values["num_vaccinated_full"]
|
||||
)
|
||||
|
||||
values["date"] = parse_date(**matches.groupdict()).strftime("%Y-%m-%d")
|
||||
result = VaccinationData(**values)
|
||||
|
||||
# Total population in Augsburg as of 2020
|
||||
# https://www.augsburg.de/fileadmin/user_upload/buergerservice_rathaus/rathaus/statisiken_und_geodaten/statistiken/Monitoring/Demografiemonitoring_der_Stadt_Augsburg_2021.pdf
|
||||
population = 299021
|
||||
# Total population in Augsburg as listed on the crawled page
|
||||
population = 298014
|
||||
|
||||
result.ratio_vaccinated_full = result.num_vaccinated_full / population
|
||||
result.ratio_vaccinated_once = result.num_vaccinated_once / population
|
||||
result.ratio_vaccinated_full = result.num_vaccinated_full / population * 100
|
||||
result.ratio_vaccinated_once = result.num_vaccinated_once / population * 100
|
||||
result.ratio_vaccinated_total = (
|
||||
result.ratio_vaccinated_once + result.ratio_vaccinated_full
|
||||
)
|
||||
result.ratio_vaccinated_booster = (
|
||||
result.num_vaccinated_booster / population * 100
|
||||
)
|
||||
_log.debug(f"Result data: {result}")
|
||||
|
||||
return result
|
||||
|
||||
@@ -1,10 +1,15 @@
|
||||
{
|
||||
"domain": "covid19_augsburg",
|
||||
"name": "COVID-19 Augsburg",
|
||||
"version": "0.1.0",
|
||||
"version": "1.2.2",
|
||||
"config_flow": true,
|
||||
"documentation": "https://github.com/AdrianoKF/home-assistant-covid19-augsburg",
|
||||
"requirements": ["beautifulsoup4==4.8.2"],
|
||||
"issue_tracker": "https://github.com/AdrianoKF/home-assistant-covid19-augsburg/issues",
|
||||
"requirements": [
|
||||
"beautifulsoup4==4.8.2"
|
||||
],
|
||||
"dependencies": [],
|
||||
"codeowners": ["@AdrianoKF"]
|
||||
}
|
||||
"codeowners": [
|
||||
"@AdrianoKF"
|
||||
]
|
||||
}
|
||||
@@ -1,3 +1,5 @@
|
||||
from dataclasses import asdict
|
||||
|
||||
from homeassistant.helpers.entity import Entity
|
||||
|
||||
from . import get_coordinator
|
||||
@@ -7,7 +9,12 @@ async def async_setup_entry(hass, _, async_add_entities):
|
||||
"""Defer sensor setup to the shared sensor module."""
|
||||
coordinator = await get_coordinator(hass)
|
||||
|
||||
async_add_entities([CoronaAugsburgSensor(coordinator)])
|
||||
async_add_entities(
|
||||
[
|
||||
CoronaAugsburgSensor(coordinator),
|
||||
CoronaAugsburgVaccinationSensor(coordinator),
|
||||
]
|
||||
)
|
||||
|
||||
|
||||
class CoronaAugsburgSensor(Entity):
|
||||
@@ -41,18 +48,59 @@ class CoronaAugsburgSensor(Entity):
|
||||
|
||||
@property
|
||||
def state(self):
|
||||
return self.coordinator.data.incidence
|
||||
return self.coordinator.data["incidence"].incidence
|
||||
|
||||
@property
|
||||
def device_state_attributes(self):
|
||||
return {
|
||||
"date": self.coordinator.data.date,
|
||||
"incidence": self.coordinator.data.incidence,
|
||||
"total_cases": self.coordinator.data.total_cases,
|
||||
"num_dead": self.coordinator.data.num_dead,
|
||||
"num_recovered": self.coordinator.data.num_recovered,
|
||||
"num_infected": self.coordinator.data.num_infected,
|
||||
}
|
||||
data = self.coordinator.data["incidence"]
|
||||
return asdict(data)
|
||||
|
||||
async def async_added_to_hass(self):
|
||||
"""When entity is added to hass."""
|
||||
self.coordinator.async_add_listener(self.async_write_ha_state)
|
||||
|
||||
async def async_will_remove_from_hass(self):
|
||||
"""When entity will be removed from hass."""
|
||||
self.coordinator.async_remove_listener(self.async_write_ha_state)
|
||||
|
||||
|
||||
class CoronaAugsburgVaccinationSensor(Entity):
|
||||
"""Representation of vaccination data for the city of Augsburg"""
|
||||
|
||||
def __init__(self, coordinator):
|
||||
"""Initialize sensor."""
|
||||
self.coordinator = coordinator
|
||||
self._name = "COVID-19 Vaccinations Augsburg"
|
||||
self._state = None
|
||||
|
||||
@property
|
||||
def available(self):
|
||||
return self.coordinator.last_update_success and self.coordinator.data
|
||||
|
||||
@property
|
||||
def name(self):
|
||||
return self._name
|
||||
|
||||
@property
|
||||
def unique_id(self):
|
||||
return self._name
|
||||
|
||||
@property
|
||||
def icon(self):
|
||||
return "mdi:needle"
|
||||
|
||||
@property
|
||||
def unit_of_measurement(self):
|
||||
return ""
|
||||
|
||||
@property
|
||||
def state(self):
|
||||
return self.coordinator.data["vaccination"].total_vaccinations
|
||||
|
||||
@property
|
||||
def device_state_attributes(self):
|
||||
data = self.coordinator.data["vaccination"]
|
||||
return asdict(data)
|
||||
|
||||
async def async_added_to_hass(self):
|
||||
"""When entity is added to hass."""
|
||||
|
||||
1021
poetry.lock
generated
1021
poetry.lock
generated
File diff suppressed because it is too large
Load Diff
@@ -1,6 +1,6 @@
|
||||
[tool.poetry]
|
||||
name = "git add re"
|
||||
version = "0.1.0"
|
||||
name = "home_assistant_covid19_augsburg"
|
||||
version = "1.2.2"
|
||||
description = ""
|
||||
authors = ["Adrian Rumpold <a.rumpold@gmail.com>"]
|
||||
packages = [
|
||||
|
||||
Reference in New Issue
Block a user