AIL/ail-framework
7
0
Fork 0
mirror of https://github.com/ail-project/ail-framework.git synced 2024-11-10 08:38:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

chg: [sync UI] dashboard, show nb of imported items + launch/kill ail servers when a queue is subscribed/unsubscribed

Browse source
This commit is contained in:
Terrtia 2021-11-30 18:08:48 +01:00
parent 0a9caf75c9
commit b7ff905e59
No known key found for this signature in database
GPG key ID: 1E1B1F50D84613D0
2 changed files with 14 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
bin/core/Sync_importer.py
View file

@ -22,10 +22,16 @@ sys.path.append(os.environ['AIL_BIN'])
# Import Project packages # Import Project packages
################################## ##################################
from core import ail_2_ail from core import ail_2_ail
from lib.ConfigLoader import ConfigLoader
from modules.abstract_module import AbstractModule from modules.abstract_module import AbstractModule
from packages.Item import Item from packages.Item import Item
from packages import Tag from packages import Tag
#### CONFIG ####
config_loader = ConfigLoader()
server_cache = config_loader.get_redis_conn("Redis_Log_submit")
config_loader = None
#### ------ ####
class Sync_importer(AbstractModule): class Sync_importer(AbstractModule):
""" """
@ -79,8 +85,8 @@ class Sync_importer(AbstractModule):
print(message) print(message)
self.send_message_to_queue(message, 'Mixer') self.send_message_to_queue(message, 'Mixer')
# # increase nb of paste by feeder name # increase nb of item by ail sync
# server_cache.hincrby("mixer_cache:list_feeder", Sync, 1) server_cache.hincrby("mixer_cache:list_feeder", 'AIL_Sync', 1)
if __name__ == '__main__': if __name__ == '__main__':

6
bin/core/ail_2_ail.py
View file

@ -945,15 +945,21 @@ def is_queue_registred_by_ail_instance(queue_uuid, ail_uuid):
return r_serv_sync.sismember(f'ail:instance:sync_queue:{ail_uuid}', queue_uuid) return r_serv_sync.sismember(f'ail:instance:sync_queue:{ail_uuid}', queue_uuid)
def register_ail_to_sync_queue(ail_uuid, queue_uuid): def register_ail_to_sync_queue(ail_uuid, queue_uuid):
is_linked = is_ail_instance_linked_to_sync_queue(ail_uuid)
r_serv_sync.sadd(f'ail2ail:sync_queue:ail_instance:{queue_uuid}', ail_uuid) r_serv_sync.sadd(f'ail2ail:sync_queue:ail_instance:{queue_uuid}', ail_uuid)
r_serv_sync.sadd(f'ail:instance:sync_queue:{ail_uuid}', queue_uuid) r_serv_sync.sadd(f'ail:instance:sync_queue:{ail_uuid}', queue_uuid)
set_last_updated_sync_config() set_last_updated_sync_config()
if not is_linked:
refresh_ail_instance_connection(ail_uuid)
# # # FIXME: TODO: delete sync queue ???????????????????????????????????????????????????? # # # FIXME: TODO: delete sync queue ????????????????????????????????????????????????????
def unregister_ail_to_sync_queue(ail_uuid, queue_uuid): def unregister_ail_to_sync_queue(ail_uuid, queue_uuid):
r_serv_sync.srem(f'ail2ail:sync_queue:ail_instance:{queue_uuid}', ail_uuid) r_serv_sync.srem(f'ail2ail:sync_queue:ail_instance:{queue_uuid}', ail_uuid)
r_serv_sync.srem(f'ail:instance:sync_queue:{ail_uuid}', queue_uuid) r_serv_sync.srem(f'ail:instance:sync_queue:{ail_uuid}', queue_uuid)
set_last_updated_sync_config() set_last_updated_sync_config()
is_linked = is_ail_instance_linked_to_sync_queue(ail_uuid)
if not is_linked:
refresh_ail_instance_connection(ail_uuid)
def get_all_unregistred_queue_by_ail_instance(ail_uuid): def get_all_unregistred_queue_by_ail_instance(ail_uuid):
return r_serv_sync.sdiff('ail2ail:sync_queue:all', f'ail:instance:sync_queue:{ail_uuid}') return r_serv_sync.sdiff('ail2ail:sync_queue:all', f'ail:instance:sync_queue:{ail_uuid}')