[ TAG 274 ][20.12.2021] -Erfolgreich -IAP-20210601-20210722

STATUS 20.01.2021

import multiprocessing
from multiprocessing import Process
from multiprocessing.sharedctypes import Value, Array
from multiprocessing.sharedctypes import RawArray
from ctypes import c_uint8


from ALOG_20210722 import GLOBALS_20210720_1330
from ALOG_20210722 import RPRCSL_20211219_0030
from STRUCT import PRTKL_202112082120 as prtkl_202112082120
from ALOG_20210722 import RPRCSL_LOGGER_20210929 as rprcsl_log
import os
import sys

# ----------------------------------------------------------------------
# PROCESS_ALOG_20210726_0110.py
# IAP-20210601-20210722-1145 > ALOG_20210722 > PROCESS_ALOG_20210726_0110.py
# PROZESS-MODUL für Audiologs
# ----------------------------------------------------------------------


def GENERATE_KWARGS_LIST(kwargs_items):
    print("")
    print(f"GENERATE_KWARGS_LIST")
    lst = {}
    for key, value in kwargs_items:
        print(f"{key}:{value}")
        lst.update({key: value})
    print("")
    return lst

def ALOG(rprcsl, **kwargs):
    print("")
    print("ALOG-PROCESS")
    print("Gebe die kwargs aus:")
    tst = kwargs.items()
    lst = GENERATE_KWARGS_LIST(kwargs_items=kwargs.items())
    print(f"tst: {tst}")
    print("")
    print(f"lst: {lst}")
    print(f"lst[lg0_idnt]: {lst['lg0_idnt']}")
    print("")
    print(f"rprcsl: {rprcsl}")
    print("")
    print("")


def GENERATE_KWARGS(alog_glb, p11_spi):
    logger_str_idnt = alog_glb.ALOG_STORAGE_IDENTIFIER
    logger_prj_idnt = alog_glb.LOGGER_IDENTIFIER
    logger_p11_spi = p11_spi
    logger_prtkl = prtkl_202112082120.ini(str_idnt=logger_str_idnt,
                                          prj_idnt=logger_prj_idnt,
                                          p11_spi=logger_p11_spi)

    alog_str_idnt = alog_glb.ALOG_STORAGE_IDENTIFIER
    alog_prj_idnt = alog_glb.ALOG_IDENTIFIER
    alog_p11_spi = p11_spi
    alog_prtkl = prtkl_202112082120.ini(str_idnt=alog_str_idnt,
                                        prj_idnt=alog_prj_idnt,
                                        p11_spi=alog_p11_spi)

    state_00 = RPRCSL_20211219_0030.STATE_00_ITEM(pid=None,
                                                  ppid=multiprocessing.process.current_process().pid,
                                                  status="status_00")

    print("")
    print("")
    print("TEST-20220120-0500")
    print(f"alog_glb.ALOG_STORAGE_IDENTIFIER: {alog_glb.ALOG_STORAGE_IDENTIFIER}")
    print(f"alog_glb.LOGGER_IDENTIFIER: {alog_glb.LOGGER_IDENTIFIER}")
    print(f"logger_prtkl[pth]: {logger_prtkl['pth'].resolve()}")
    print(f"logger_prtkl[idnt]: {logger_prtkl['idnt']}")
    print("")
    print(f"alog_prtkl[pth]: {alog_prtkl['pth']}")
    print(f"alog_prtkl[idnt]: {alog_prtkl['idnt']}")
    print("")
    print(f"state_00: {state_00}")
    print(f"state_00[state_00][ppid]:{state_00['state_00']['ppid']}")
    print(f"state_00[state_00][t0]:{state_00['state_00']['t0']}")
    print(f"state_00[state_00][t1]:{state_00['state_00']['t1']}")
    print(f"state_00[state_00][t2]:{state_00['state_00']['t2']}")
    print("")
    print("")

    kwargs = {'lg0_idnt': logger_prtkl['idnt'],
              'lg0_pth': logger_prtkl['pth'].resolve(),
              'lg0_str_idnt': logger_str_idnt,
              'lg0_prj_idnt': logger_prj_idnt,
              'lg0_p11_spi': logger_p11_spi,
              'alg_idnt': alog_prtkl['idnt'],
              'alg_pth': alog_prtkl['pth'],
              'alg_str_idnt': alog_str_idnt,
              'alg_prj_idnt': alog_prj_idnt,
              'alg_p11_spi': alog_p11_spi,
              'st0_ppid': state_00["state_00"]["ppid"],
              'st0_t0': state_00["state_00"]["t0"],
              'st0_t1': state_00["state_00"]["t1"],
              'st0_t2': state_00["state_00"]["t2"]
              }
    return kwargs


def START_PROCESS(alog_glb):
    print(f"START_PROCESS -> START_PROCESS(alog_glb) wird ausgeführt.")
    kwargs = GENERATE_KWARGS(alog_glb=alog_glb, p11_spi="DEON")
    p = Process(target=ALOG, args=(alog_glb.RPRCSL,), kwargs=kwargs)
    p.start()
    pid = p.pid
    ppid = multiprocessing.process.current_process().pid

    print("")
    print(f"--> Prozess wurde gestartet.")
    print(f"--> pid: {pid}")
    print(f"--> ppid: {ppid}")
    print("")

    p.join()
    print("")
    print(f"--> Prozess wurde beendet.")
    print(f"alog_glb.RPRCSL: {alog_glb.RPRCSL}")
    print("")


def STOP_LAST_PROCESS(alog_glb):
    print("STOP_LAST_PROCESS")

AUSGABE

TEST-20220120-0500
alog_glb.ALOG_STORAGE_IDENTIFIER: ext_prj_2021
alog_glb.LOGGER_IDENTIFIER: LOGGER
logger_prtkl[pth]: E:\LOGGER\2022\01\20\DEON_20220120_0559-0
logger_prtkl[idnt]: DEON_20220120_0559-0

alog_prtkl[pth]: E:\ALOG\2022\01\20\DEON_20220120_0559-0
alog_prtkl[idnt]: DEON_20220120_0559-0

state_00: {
    'state_00': {
        'pid': None,
        'ppid': 20396,
        'status': 'status_00',
        't0': 1642654795.8138566,
        't1': '2022-01-20 05:59:55',
        't2': 1642654795813856400
    }
}
state_00[state_00][ppid]:20396
state_00[state_00][t0]:1642654795.8138566
state_00[state_00][t1]:2022-01-20 05:59:55
state_00[state_00][t2]:1642654795813856400



--> Prozess wurde gestartet.
--> pid: 2640
--> ppid: 20396

ALOG_20210722.GLOBALS_20210720_1330 - GLOBALS_20210720_1330
name:MKI_20210819.MKI_MAIN_20210819 MKI_MAIN_20210819

ALOG-PROCESS
Gebe die kwargs aus:

GENERATE_KWARGS_LIST
lg0_idnt:DEON_20220120_0559-0
lg0_pth:E:\LOGGER\2022\01\20\DEON_20220120_0559-0
lg0_str_idnt:ext_prj_2021
lg0_prj_idnt:LOGGER
lg0_p11_spi:DEON
alg_idnt:DEON_20220120_0559-0
alg_pth:E:\ALOG\2022\01\20\DEON_20220120_0559-0
alg_str_idnt:ext_prj_2021
alg_prj_idnt:ALOG
alg_p11_spi:DEON
st0_ppid:20396
st0_t0:1642654795.8138566
st0_t1:2022-01-20 05:59:55
st0_t2:1642654795813856400

tst: dict_items(
    [
        ('lg0_idnt', 'DEON_20220120_0559-0'),
        ('lg0_pth', WindowsPath('E:/LOGGER/2022/01/20/DEON_20220120_0559-0')),
        ('lg0_str_idnt', 'ext_prj_2021'),
        ('lg0_prj_idnt', 'LOGGER'),
        ('lg0_p11_spi', 'DEON'),
        ('alg_idnt', 'DEON_20220120_0559-0'),
        ('alg_pth', WindowsPath('E:/ALOG/2022/01/20/DEON_20220120_0559-0')),
        ('alg_str_idnt', 'ext_prj_2021'),
        ('alg_prj_idnt', 'ALOG'),
        ('alg_p11_spi', 'DEON'),
        ('st0_ppid', 20396),
        ('st0_t0', 1642654795.8138566),
        ('st0_t1', '2022-01-20 05:59:55'),
        ('st0_t2', 1642654795813856400)
    ]
)

lst: {
    'lg0_idnt': 'DEON_20220120_0559-0',
    'lg0_pth': WindowsPath('E:/LOGGER/2022/01/20/DEON_20220120_0559-0'),
    'lg0_str_idnt': 'ext_prj_2021',
    'lg0_prj_idnt': 'LOGGER',
    'lg0_p11_spi': 'DEON',
    'alg_idnt': 'DEON_20220120_0559-0',
    'alg_pth': WindowsPath('E:/ALOG/2022/01/20/DEON_20220120_0559-0'),
    'alg_str_idnt': 'ext_prj_2021',
    'alg_prj_idnt': 'ALOG',
    'alg_p11_spi': 'DEON',
    'st0_ppid': 20396,
    'st0_t0': 1642654795.8138566,
    'st0_t1': '2022-01-20 05:59:55',
    'st0_t2': 1642654795813856400
}
lst[lg0_idnt]: DEON_20220120_0559-0

rprcsl: {}



--> Prozess wurde beendet.
alog_glb.RPRCSL: {}