Как можна приобразовать клас в str и обратно?

Question

[Rotyin]

client = telethon.TelegramClient(akk,api_id,api_hash)
self.dop_list[akk] = [client]

Выходит: TelegramBaseClient.__init__.._Loggers

я приобразовую этот клас в строку:

str(TelegramBaseClient.__init__.<locals>._Loggers)

как мне назад вернуть этот клас, но уже не в виде строки?

Answer 1

[asysprotri]

Вы можете сохранять сразу классом, а не переводить в строку

Comments

[Rotyin]

но поток не пускает, выдвет ошыбку:

AttributeError: Can't pickle local object 'TelegramBaseClient.__init__.<locals>._Loggers'

[Vindicar]

Rotyin, тут одно из двух.
1. Это не поток, а процесс. Тогда на кой огурец ты берёшься писать многопроцессного бота? Это задача мало того что нетривиальная, я и сам с трудом представляю как к ней подобраться. Для чего тебе могло такое чудо потребоваться?
2. Это всё-таки поток. Но тогда зачем ты используешь ограниченный (и небезопасный) pickle для передачи данных между потоками?

[Rotyin]

Vindicar, мне понадобились процессы для одновременного использования нескольких акаунтов одновременно

[Vindicar]

Rotyin, почему не подошли потоки для того же? Кроме того, можно использовать aiogram и попробовать запустить несколько ботов в одном потоке. Вполне может сработать.

[Rotyin]

Vindicar, Можна и с aiogram.

[Rotyin]

Vindicar, А уже не важно, я решил проблему другим способом

[Rotyin]

Vindicar,

for i in akks:
                loop = asyncio.new_event_loop()
                loop.run_until_complete(start(akk,audio,chat))
                time.sleep(times+7)





async def start(akk,audio,chat):
    async with telethon.TelegramClient(akk,api_id,api_hash) as client:

        await client(JoinChannelRequest(chat))

        group_call = pytgcalls.GroupCallFactory(client, CLIENT_TYPE).get_file_group_call(audio, "",play_on_repeat=False)

        await group_call.start(chat)

        await client.run_until_disconnected()

не, asyncio не работает

[Rotyin]

Vindicar,

for akk in akks:
                proc = Process(target=get_start, args=(akk, audio, chat,))
                proc.start()
                print("next")
                time.sleep(times+7)




def get_start(akk,audio,chat):
    loop = asyncio.get_event_loop()
    loop.run_until_complete(start(akk,audio,chat))



async def start(akk,audio,chat):
    async with telethon.TelegramClient(akk,api_id,api_hash) as client:

        await client(JoinChannelRequest(chat))

        group_call = pytgcalls.GroupCallFactory(client, CLIENT_TYPE).get_file_group_call(audio, "",play_on_repeat=False)

        await group_call.start(chat)

        await pyrogram.idle()

в моем примере это работает

[Vindicar]

Rotyin, это не asyncio не работает, это ты абсолютно не понимаешь как им пользоваться. -_-

loop = asyncio.get_event_loop()
akks = ... #тут твой код
audio = ... #тут твой код
chat = ... #тут твой код

async def start(akk,audio,chat):
    pass #тут твой код

async def run_all(akks):
    # выполняем все копии start() параллельно в одном потоке и в одном loop
    tasks = [start(akk, audio, chat) for akk in akks ]
    await asyncio.gather(*tasks) 

loop.run_untiL_complete(run_all(akks))

[Rotyin]

Vindicar,

async def main():
    with open('seting.json',"r") as f:
        contents = json.loads(f.read())
        name = contents["content"]
        chat = '@testingci'
        dop_list = {"e":'e'}
        tasks = []
        for i in name:
            if type(i) == type([]):
                akk = "akk/" + i[0]
                audio = "media/" + i[1]
                tasks.append(start(akk,audio,chat))
        await asyncio.gather(*tasks)







async def start(akk,audio,chat):

    async with telethon.TelegramClient(akk,api_id,api_hash) as client:

        await client(JoinChannelRequest(chat))

        group_call = pytgcalls.GroupCallFactory(client, CLIENT_TYPE).get_file_group_call(audio, "",play_on_repeat=False)

        await group_call.start(chat)

        await pyrogram.idle()







loop = asyncio.get_event_loop()
loop.run_until_complete(main())

всеравно не работает(

[Vindicar]

Rotyin, как именно не работает?
Входит ли вообще в start()? Выдаёт ли сообщения об ошибке? Как насчёт завернуть содержимое start() в try-except и логгировать исключения?

[Rotyin]

Vindicar, оно только первое start обрабатывает.
start() ничего не возвращает через функцию pyrogram.idle() она поддерживает работу акаунта чтобы он не дисконектнулся, потому она держит весь главный поток. И дальше код не обрабатывается. И потому я решил использовать Process

[Vindicar]

Rotyin, погоди-ка... согласно документации, pyrogram.idle() это вообще не асинхронная функция. Почему ты делаешь ей await?
И потом, а нафиг она тебе? Она нужна только чтобы держать в ступоре главный поток. У тебя главный поток занят выполнением цикла asyncio из-за run_untile_complete(). Цикл будет крутиться, пока все копии start() не отработают. Просто задержи работу start() насколько тебе нужно, например, через ожидание asyncio.Event.
И еще потом, а причем тут вообще pyrogram если ты используешь telethon? Это ж две разные библиотеки?

[Rotyin]

Vindicar, я использую await pyrogram.idle() потому что функция start асинхронная, асинхронная потому что pytgcalls асинхронная библиотека.

Я пробовал вместо idle client.start(), не работает.
Пробовал client.run_until_compated() она похожа на idle, задерживает поток но работает медленнее. Вот почему я решыл использовать idle.

[Vindicar]

Rotyin, погоди, дело не в том. Это вообще разные библиотеки, почему ты ожидаешь что они будут знать друг о друге и как-то кооперироваться?
И потом, от того что ты написал перед функцией await, она асинхронной не станет.

[Rotyin]

Vindicar, да, они каким-то образом работают))
А пишу await потомучто ошыбка нужно написать await
Глянь на пример: https://github.com/MarshalX/tgcalls/blob/main/exam...

[Vindicar]

Rotyin, читал пример по-диагонали?

# choose one of this
import telethon
import pyrogram

Засунь фразу в гугло переводчик, если английского не знаешь.
Пример содержит код для обоих библиотек, тебе нужно оставить одну их них.

[Rotyin]

Vindicar, но pyrogram.idle() работает))

[Vindicar]

Rotyin, ну да, только вот ты не можешь заставить программу работать как надо.
Оно работает, потому что pyrogram.idle() никогда не возвращает значение, а не возвращает он значение потому что нет ни одного pyrogram-клиента - все клиенты на telethon, и pyrogram о них не знает.
В общем, я тебе уже выше написал что делать. Создаёшь глобальный event = asyncio.Event(), и в start() просто делаешь await event.wait(). Это подвесит выполнение start(), но не помешает всему остальному.
Когда надо будет завершить работу программы, сделаешь event.set(), и это завершит все копии start().