Skip to content
Snippets Groups Projects

Add extension registration periodic

Merged Eterevskiy Georgiy requested to merge feature/add_periodic_extension_registration into master
3 files
+ 11
5
Compare changes
  • Side-by-side
  • Inline
Files
3
 
import aiocron
import grpc
import grpc
import logging
import logging
from concurrent import futures
from concurrent import futures
from perxis.extensions import manager_pb2
from perxis.collections import collections_pb2_grpc
from perxis.collections import collections_pb2_grpc
from perxis.environments import environments_pb2_grpc
from perxis.environments import environments_pb2_grpc
from perxis.roles import roles_pb2_grpc
from perxis.roles import roles_pb2_grpc
@@ -22,6 +22,13 @@ def bootstrap(
@@ -22,6 +22,13 @@ def bootstrap(
interceptor = header_adder_interceptor(
interceptor = header_adder_interceptor(
'x-perxis-access', 'system'
'x-perxis-access', 'system'
)
)
 
 
@aiocron.crontab('* * * * *', start=False)
 
def register_extension():
 
ext_manager_stub.RegisterExtensions(manager_pb2.RegisterExtensionsRequest(
 
extensions=[ext_descriptor]
 
))
 
with grpc.insecure_channel(ext_manager_host) as extensions_manager_channel:
with grpc.insecure_channel(ext_manager_host) as extensions_manager_channel:
intercept_channel_extensions_manager_channel = grpc.intercept_channel(extensions_manager_channel, interceptor)
intercept_channel_extensions_manager_channel = grpc.intercept_channel(extensions_manager_channel, interceptor)
@@ -43,9 +50,7 @@ def bootstrap(
@@ -43,9 +50,7 @@ def bootstrap(
# f"Изменилась версия расширения {ext_descriptor.extension} ({ext.version} -> {ext_descriptor.version})"
# f"Изменилась версия расширения {ext_descriptor.extension} ({ext.version} -> {ext_descriptor.version})"
# )
# )
ext_manager_stub.RegisterExtensions(manager_pb2.RegisterExtensionsRequest(
register_extension()
extensions=[ext_descriptor]
))
logger.info(f"Расширение {ext_descriptor.extension} зарегистрировано в perxis")
logger.info(f"Расширение {ext_descriptor.extension} зарегистрировано в perxis")
Loading