This commit is contained in:
@@ -11,7 +11,8 @@ from bs4 import BeautifulSoup
|
|||||||
import requests
|
import requests
|
||||||
from argparse import ArgumentParser, ArgumentDefaultsHelpFormatter
|
from argparse import ArgumentParser, ArgumentDefaultsHelpFormatter
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
from api import Server, get_api_config, get_logger
|
from api import Server, get_api_config
|
||||||
|
from log import get_logger
|
||||||
from db.models.media import MediaActor, MediaActorFile, MediaFile
|
from db.models.media import MediaActor, MediaActorFile, MediaFile
|
||||||
|
|
||||||
parser = ArgumentParser(formatter_class=ArgumentDefaultsHelpFormatter)
|
parser = ArgumentParser(formatter_class=ArgumentDefaultsHelpFormatter)
|
||||||
@@ -182,7 +183,7 @@ if __name__ == "__main__":
|
|||||||
media_actor_file.last_modified_date = datetime.now()
|
media_actor_file.last_modified_date = datetime.now()
|
||||||
media_actor_file.version = 0
|
media_actor_file.version = 0
|
||||||
media_actor_file.media_file_id = media_file.id
|
media_actor_file.media_file_id = media_file.id
|
||||||
media_actor_file.media_actor_id = media_actor["id"]
|
media_actor_file.media_actor_id = media_actor.id
|
||||||
logger.info("create mapping with %s", media_actor_file)
|
logger.info("create mapping with %s", media_actor_file)
|
||||||
if not args.dry_run:
|
if not args.dry_run:
|
||||||
logger.info("add MediaFile Actor mapping %s", media_actor_file)
|
logger.info("add MediaFile Actor mapping %s", media_actor_file)
|
||||||
|
|||||||
@@ -1,15 +1,9 @@
|
|||||||
import logging
|
|
||||||
|
|
||||||
import stomp
|
import stomp
|
||||||
import logging.config
|
|
||||||
import time
|
import time
|
||||||
import yaml
|
|
||||||
import msgspec
|
import msgspec
|
||||||
import sys
|
import sys
|
||||||
from pathlib import Path
|
|
||||||
from argparse import ArgumentParser, ArgumentDefaultsHelpFormatter
|
from argparse import ArgumentParser, ArgumentDefaultsHelpFormatter
|
||||||
from typing import Any, Dict, List, Optional
|
from typing import Optional
|
||||||
from platformdirs import PlatformDirs
|
|
||||||
from api import Server, get_api_config
|
from api import Server, get_api_config
|
||||||
from log import get_logger
|
from log import get_logger
|
||||||
|
|
||||||
@@ -17,7 +11,8 @@ from log import get_logger
|
|||||||
parser = ArgumentParser(formatter_class=ArgumentDefaultsHelpFormatter)
|
parser = ArgumentParser(formatter_class=ArgumentDefaultsHelpFormatter)
|
||||||
parser.add_argument('--verbose', '-v', action='count', default=0)
|
parser.add_argument('--verbose', '-v', action='count', default=0)
|
||||||
parser.add_argument("--config", "-c", default="kontor-api")
|
parser.add_argument("--config", "-c", default="kontor-api")
|
||||||
parser.add_argument("--server", "-s", default="127.0.0.1")
|
parser.add_argument("--server", "-s")
|
||||||
|
parser.add_argument("--messages", "-m", default="127.0.0.1")
|
||||||
parser.add_argument("--port", "-p", default="61616")
|
parser.add_argument("--port", "-p", default="61616")
|
||||||
args = parser.parse_args()
|
args = parser.parse_args()
|
||||||
|
|
||||||
@@ -65,7 +60,7 @@ if __name__ == '__main__':
|
|||||||
if not first_server:
|
if not first_server:
|
||||||
sys.exit(2)
|
sys.exit(2)
|
||||||
data = first_server.request(log=logger, table="media_file")
|
data = first_server.request(log=logger, table="media_file")
|
||||||
host = [(args.server, args.port)]
|
host = [(args.messages, args.port)]
|
||||||
conn_add = stomp.Connection(host_and_ports=host)
|
conn_add = stomp.Connection(host_and_ports=host)
|
||||||
conn_add.set_listener('', AddLinkListener(logger, conn_add))
|
conn_add.set_listener('', AddLinkListener(logger, conn_add))
|
||||||
conn_add.connect(username='artemis', passcode='artemis', wait=True)
|
conn_add.connect(username='artemis', passcode='artemis', wait=True)
|
||||||
|
|||||||
@@ -11,9 +11,9 @@ from api import (
|
|||||||
MAPPING,
|
MAPPING,
|
||||||
EndPointNotAvailableException,
|
EndPointNotAvailableException,
|
||||||
Server,
|
Server,
|
||||||
get_api_config,
|
get_api_config
|
||||||
get_logger,
|
|
||||||
)
|
)
|
||||||
|
from log import get_logger
|
||||||
|
|
||||||
parser = ArgumentParser(formatter_class=ArgumentDefaultsHelpFormatter)
|
parser = ArgumentParser(formatter_class=ArgumentDefaultsHelpFormatter)
|
||||||
parser.add_argument("--verbose", "-v", action="count", default=0)
|
parser.add_argument("--verbose", "-v", action="count", default=0)
|
||||||
|
|||||||
Reference in New Issue
Block a user