dm1sh/lenengro_parser
1
0
Fork 0
Code Pull Requests Activity

Renamed base parser class and creds

Browse Source
This commit is contained in:
Dmitriy Shishkov 2023-10-11 20:51:43 +03:00
parent 620a6a820f
commit b52be1a89c
Signed by: dm1sh
GPG Key ID: 027994B0AA357688
5 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
.env.example
View File

@ -1,5 +1,5 @@
REFETCH_PERIOD_H=6 REFETCH_PERIOD_H=6
POSTGRES_USER=rosseti POSTGRES_USER=lenenergo
POSTGRES_PASSWORD=rosseti POSTGRES_PASSWORD=lenenergo
POSTGRES_DB=rosseti POSTGRES_DB=lenenergo
POSTGRES_HOST=db POSTGRES_HOST=db

4
parser/__init__.py
View File

@ -12,11 +12,11 @@ from .preprocess import (
preprocess_df, preprocess_df,
preprocess_read_df, preprocess_read_df,
) )
from .rosseti import RossetiParser from .lenenergo import LenenergoParser
from .util import pipeline from .util import pipeline
__all__ = ( __all__ = (
"RossetiParser", "LenenergoParser",
"split_addresses", "split_addresses",
"get_building_id", "get_building_id",
"fetch_builing_ids", "fetch_builing_ids",

0
parser/rosseti.py → parser/lenenergo.py
View File

6
parser/util.py
View File

@ -1,16 +1,16 @@
from typing import Optional from typing import Optional
from . import ( from . import (
RossetiParser, LenenergoParser,
concurrent_fetch_builing_ids, concurrent_fetch_builing_ids,
preprocess_df, preprocess_df,
split_addresses, split_addresses,
) )
def pipeline(parser: Optional[RossetiParser] = None) -> RossetiParser: def pipeline(parser: Optional[LenenergoParser] = None) -> LenenergoParser:
if parser is None: if parser is None:
parser = RossetiParser() parser = LenenergoParser()
print(parser) print(parser)

6
runner/config.py
View File

@ -2,8 +2,8 @@ import os
REFETCH_PERIOD_H = int(os.environ.get("REFETCH_PERIOD_H", "4")) REFETCH_PERIOD_H = int(os.environ.get("REFETCH_PERIOD_H", "4"))
POSTGRES_USER = os.environ.get("POSTGRES_USER", "rosseti") POSTGRES_USER = os.environ.get("POSTGRES_USER", "lenenegro")
POSTGRES_PASSWORD = os.environ.get("POSTGRES_PASSWORD", "rosseti") POSTGRES_PASSWORD = os.environ.get("POSTGRES_PASSWORD", "lenenegro")
POSTGRES_DB = os.environ.get("POSTGRES_DB", "rosseti") POSTGRES_DB = os.environ.get("POSTGRES_DB", "lenenegro")
POSTGRES_HOST = os.environ.get("POSTGRES_HOST", "localhost") POSTGRES_HOST = os.environ.get("POSTGRES_HOST", "localhost")
POSTGRES_PORT = int(os.environ.get("POSTGRES_PORT", "5432")) POSTGRES_PORT = int(os.environ.get("POSTGRES_PORT", "5432"))