Base application context

Module contains base application and request class.

class luna_python_matcher.app_common.base_application.MatcherBaseApp(*args, **kwargs)

Base service application

async static checkConnectionToAttributesDB(dbSettings)

Check connections to temporary attributes db :param dbSettings: redis settings

Returns

True, if check was passed successfully, else False.

Return type

bool

async static checkConnectionToEventsDB(dbSettings)

Check connections to events db :param dbSettings: database settings

Returns

True, if check was passed successfully, else False.

Return type

bool

async static checkConnectionToFacesDB(dbSettings)

Check connections to faces db :param dbSettings: database settings

Returns

True, if check was passed successfully, else False.

Return type

bool

initContexts()

Initialize faces, events and attributes databases context

Return type

None

async initDBContext()

Initialize faces & events database context.

async initRedisDB(redisDBSettings)

Initialize Redis client. :param redisDBSettings: redis db settings

async initialize()

Initialize application.

async shutdown()

Shutdown application services.

class luna_python_matcher.app_common.base_application.MatcherBaseCtx

Base luna-python-matcher context

attributesDBContext: db.context_attributes.RedisContext

attributes database context

eventsDBAdaptor: Optional[crutches_on_wheels.adaptors.adaptor.DBAdaptor]

events database adaptor

eventsDBContext: db.context_events.DBContext

events database context

facesDBAdaptor: Optional[crutches_on_wheels.adaptors.adaptor.DBAdaptor]

faces database adaptor

facesDBContext: db.context_faces.DBContext

faces database context

redisClient: Optional[aioredis.commands.Redis]

redis client

Luna Python Matcher application context

Sanic application server.

class luna_python_matcher.app.app.PythonMatcherApp

Python matcher application

getRuntimeChecks(includeLunaServices=False)

Returns configured system checks, pairs of (name, coroutine).

Parameters

includeLunaServices – A bool, whether to include checks for luna services.

Return type

List[Tuple[str, Awaitable]]

async initialize()

Initialize application.

initializeMatcher()

Initialize matcher and matcherlib and pass reference to the matcher to clients.

It’s important to configure logging first.

async shutdown()

Shutdown application services.

class luna_python_matcher.app.app.PythonMatcherCtx

Python matcher application context

matcher: Optional[pymatcherlib.pymatcherlib.Matcher]

matcher

async luna_python_matcher.app.app.checkCachedMatcherProcess(app, loop)

Check connection to Cached Matcher. Terminate Sanic process if connection check failed. :param app: python matcher application :param loop: event loop

Return type

None

Luna Python Matcher Proxy application context

Application server.

class luna_python_matcher.app_proxy.app.PythonMatcherProxyApp

Python matcher proxy application

getQueueSettings(settings)

Get queue settings for matcher-proxy. :param settings: settings

Returns

QueueSettings

Return type

QueueSettings

getRuntimeChecks(includeLunaServices=False)

Returns configured system checks, pairs of (name, coroutine).

Parameters

includeLunaServices – A bool, whether to include checks for luna services.

Return type

List[Tuple[str, Awaitable]]

initLunaClient(settings)

Initialize session to internal services.

async initialize()

Initialize application.

async shutdown()

Shutdown application services.

class luna_python_matcher.app_proxy.app.PythonMatcherProxyCtx

Python matcher application context

dispatcher: app_proxy.matcher.dispatcher.Dispatcher

dispatcher for matching

luna3Session: Optional[luna3.client.Luna3Session]

luna3 client