Как разделить данные между экземплярами сервера на asyncio?

Question

[Midzakikayo]

Доброго времени! Продолжаю долгое самообучение Python3 на курсе и столкнулся с вопросом.
Прошу совета!

Есть сервер:

import asyncio

class ClientServerportocol(asyncio.Protocol):
    DATA = {}

    def connection_made(self, transport):
        self.transport = transport
        self.ip = transport.get_extra_info('peername')
        print('connect from:', self.ip)

    #Форматируем данные по типу
    def recompl(self, data):
       *****
    #Получение запросов и обработка
    def data_received(self, data: bytes):
       *****
    #запись данных на сервер
    def put(self, requests):
       *****
    #получение данных c сервера
    def get(self, requests):
       *****
#запуск сервера
def run_server(host='', port=9001):
    loop = asyncio.get_event_loop()
    coro = loop.create_server(ClientServerportocol, host, port)
    server = loop.run_until_complete(coro)
    try:
        loop.run_forever()
    except KeyboardInterrupt:
        print("Server stoped with,", "KeyboardInterrupt".upper())
    server.close()
    loop.run_until_complete(server.wait_closed())
    loop.close()

Нужно разделить данные между его экземплярами.
Тема с asyncio оказалась для меня слишком тугой. Почитав таки понял что и с чем едят. Но вот только уперся в другое. Как отделить данные. между разными экземплярами серверов на asyncio.

Использовать переменную класса не получится, так как она общая для всех экземпляров.
Использовать переменную экземпляра класса это уткнуться в короткий срок её жизни в рамках одного подключения.
И тут встаёт вопрос как это реализовать?

Comments

[Alexa2007]

Не уверен, но возможно это

Answer 1

[javedimka]

Твой сервер и так поддерживает соединение.

Начни изучение с более низкоуровневых вещей, а не с этого.

Comments

[Midzakikayo]

К сожалению или cчастью дали такое задание. Тема с asyncio оказалась для меня слишком тугой. Почитав таки понял что и с чем едят. Но вот только уперся в другое. Как отделить данные. между разными экземплярами серверов на asyncio. Ибо использовать переменную класса не получится, так как она общая для всех экземпляров. использовать переменную класса это уткнуться в короткий срок её жизни в рамках одного подключения. И тут встаёт вопрос как? как это реализовать?
PS. Спасибо огромное Вам за ответ!

[javedimka]

Midzakikayo, Всегда надо читать доку.

Если это с курса на курсере и задание про метрики, то когда меня просили его сделать, то я сделал примерно так, открыл доку, нашёл функцию create_server:
https://docs.python.org/3/library/asyncio-eventloo...
Читаешь описание, что она в себя принимает:

protocol_factory must be a callable returning a protocol implementation.

Ок, коллабл значит, переписываешь свой ран сервер и добавляешь __init__ в свой протокол:

class ClientServerportocol(asyncio.Protocol):
    def __init__(self, database):
         self.db = database

....

def run_server(host='', port=9001):
    ...
    coro = loop.create_server(lambda: ClientServerportocol(myDatabaseClass()), host, port)
    ...

ну и запускаешь сколько тебе надо серверов, каждый с своей базой работать будет.

run_server('127.0.0.1', 9001)
run_server('127.0.0.1', 9002)

В любой непонятной ситуации нужно читать доку.