ashatora/xmlrpcserver
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix bndname in replication

Browse Source
This commit is contained in:
Ivan Vazhenin
2023-11-09 10:41:43 +07:00
parent 5b17bba5bf
commit 36e23465a8
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
db.py
View File

@@ -2,6 +2,7 @@ from datetime import datetime
from typing import List, Optional from typing import List, Optional
from sqlalchemy import create_engine, String, select, ForeignKey, Enum from sqlalchemy import create_engine, String, select, ForeignKey, Enum
from sqlalchemy.orm import Session, DeclarativeBase, Mapped, mapped_column, relationship from sqlalchemy.orm import Session, DeclarativeBase, Mapped, mapped_column, relationship
from config import Config
def tow(day: int, hour: int, minute: int): def tow(day: int, hour: int, minute: int):
@@ -133,4 +134,4 @@ class Schemas(Base):
def connect_db(): def connect_db():
return create_engine("postgresql+psycopg://postgres:Root12345678@10.10.8.83:32101/db") return create_engine(f"postgresql+psycopg://{Config.pg_username}:{Config.pg_password}@{Config.pg_host}:{Config.pg_port}/{Config.pg_dbname}")

3
main.py
View File

@@ -70,7 +70,6 @@ def run_tasks():
def replication_task(): def replication_task():
while True: while True:
print()
conn = db.connect_db() conn = db.connect_db()
with Session(conn) as session: with Session(conn) as session:
for bndname in connected: for bndname in connected:
@@ -241,7 +240,7 @@ def replication(bnd_name: str, commit_id: str, schema: str):
ET.SubElement(res, 'replication', {'id': commit_id, 'scheme': schema}) ET.SubElement(res, 'replication', {'id': commit_id, 'scheme': schema})
response_params = { response_params = {
'from': f'tcp://{Config.self_bnd}', 'from': f'tcp://{Config.self_bnd}',
'to': f'tcp://{Config.remote_bnd}', 'to': f'tcp://{bnd_name}',
'ts_added': date.timestamp(), 'ts_added': date.timestamp(),
'user_id': '0', 'user_id': '0',
'query_type': NEW_REPLICATION_REQUEST, 'query_type': NEW_REPLICATION_REQUEST,