s
это как?
Внутри процесса открываешь сабпроуесс в котором разворачиваешь вторую сессию. Или я тебя не правильно понял
Size: a a a
2019 September 05
S
Сабпроцессом
каким сабпроцессом
асинкио отрыгнет таски при первой попытке запуска их в другом потоке в одном лупе
асинкио отрыгнет таски при первой попытке запуска их в другом потоке в одном лупе
NK
Сабпроцессом
what what?
NK
S
ID:313742192
what what?
Да пиздец, я аж в чат зашел
s
ID:313742192
what what?
Это кстати было решением моей задачи
s
Хелпер юзербот
K0
Жёстко, но зачем
СУ
ну я вообще сначала хотел клиентов по потокам распихать
СУ
но понимаю, что всё можно сделать асинхронно в одном потоке
СУ
но не понимаю как сделать таски
NK
как можно в одном эвентлупе слушать нескольких клиентов?
так....
NK
как можно в одном эвентлупе слушать нескольких клиентов?
import asyncio
from telethon import TelegramClient, events
loop = asyncio.get_event_loop()
ph_num1 = '...'
ph_num2 = '...'
api_id = 8
api_hash = '7245de8e747a0d6fbe11f7cc14fcc0bb'
client = TelegramClient(ph_num1, api_id, api_hash)
client_2 = TelegramClient(ph_num2, api_id, api_hash)
loop.create_task(client.start())
loop.create_task(client_2.start())
loop.run_forever()NK
ты об этом?
СУ
не совсем
СУ
надо чтобы каждый клиент слушал определённый канал
NK
или про треды?
NK
import logging
logging.basicConfig(level=logging.DEBUG)
from threading import Thread as T
from telethon import TelegramClient as C
from telethon.events import NewMessage
import asyncio
from con import aid, ahash, t1, t2
async def t():
c1 = C(None, aid, ahash)
await c1.start(bot_token=t1)
c2 = C(None, aid, ahash)
await c2.start(bot_token=t2)
async def a(b):
await b.reply('b')
c1.add_event_handler(NewMessage, a)
c2.add_event_handler(NewMessage, a)
def tt(k):
asyncio.set_event_loop(k)
k.run_until_complete(t())
k.run_forever()
l = asyncio.new_event_loop()
T(target=tt, args=(l,)).start()
s
ID:313742192
import asyncio
from telethon import TelegramClient, events
loop = asyncio.get_event_loop()
ph_num1 = '...'
ph_num2 = '...'
api_id = 8
api_hash = '7245de8e747a0d6fbe11f7cc14fcc0bb'
client = TelegramClient(ph_num1, api_id, api_hash)
client_2 = TelegramClient(ph_num2, api_id, api_hash)
loop.create_task(client.start())
loop.create_task(client_2.start())
loop.run_forever()Телетон позволяет запускать два клиента в одной сессии?
СУ
ну типа вот так
@client.on(events.NewMessage(incoming=True, from_users=[777000]))
async def my_event_handler(event):
sents = [sent.text for sent in sentenize(event.raw_text)]
print(f"{phone} - {sents[0]}")
@client.on(events.NewMessage(incoming=True, from_users=[777000]))
async def my_event_handler(event):
sents = [sent.text for sent in sentenize(event.raw_text)]
print(f"{phone} - {sents[0]}")