Ошибка соединения, когда соединение уже установлено - PullRequest
Новая
       25

Ошибка соединения, когда соединение уже установлено

0 голосов
/ 20 декабря 2018

Я использую Telethon == 1.4.3 в своем коде: 

import telepot
import threading
from telethon import TelegramClient
from flask import Flask, request
from telepot.loop import OrderedWebhook
from telepot.delegate import (
    per_chat_id, create_open, pave_event_space, include_callback_query_chat_id)

class Main_Class(telepot.helper.ChatHandler):
    def __init__(self, *args, **kwargs):
        super(Main_Class, self).__init__(*args, **kwargs)

    def on_chat_message(self, msg):
        content_type, chat_type, chat_id = telepot.glance(msg)
        if content_type == 'text':
            client = TelegramClient('session_name', api_id, api_hash)
            client.connect()
            client.send_message('me', 'Hello World from Telethon!')            

app = Flask(__name__)
@app.route('/', methods=['GET', 'POST'])
def pass_update():
    webhook.feed(request.data)
    return 'OK'
TOKEN = my_token
bot = telepot.DelegatorBot(TOKEN, [
    include_callback_query_chat_id(
        pave_event_space())(
        per_chat_id(types=['private']), create_open, Main_Class, timeout=100000),
])
webhook = OrderedWebhook(bot)

webhook.run_as_thread()

Поскольку я также использую колбу, эти два мешают друг другу, и я получил следующую ошибку: 

RuntimeError: There is no current event loop in thread 'Thread-1'

Я импортировал asyncio и добавил следующие строки в код, и проблема была решена 

class Main_Class(telepot.helper.ChatHandler):
     ......
     loop = asyncio.new_event_loop()
     client = TelegramClient('session_name', api_id, api_hash,loop=loop)
     loop.run_until_complete(goo(loop,client))
     loop.close()
 .....

async def goo(loop,client):
      client.connect()
      await client.send_message('me', 'Hello World from Telethon!')

Следующая ошибка возникает несмотря на то, что я уже установил соединение: 

ConnectionError: Cannot send requests while disconnected

1 Ответ

0 голосов
/ 11 января 2019

Вам также следует дождаться завершения соединения.Потому что это делается асинхронно. 

async def goo(loop,client):
      await client.connect()
      await client.send_message('me', 'Hello World from Telethon!')

Подробнее, здесь .

...