Şimdi Ara

Task was destroyed but it is pending! sorunu çözümü. Lütfen yardım edin

Daha Fazla
Bu Konudaki Kullanıcılar: Daha Az
2 Misafir - 2 Masaüstü
5 sn
3
Cevap
0
Favori
468
Tıklama
Daha Fazla
İstatistik
  • Konu İstatistikleri Yükleniyor
0 oy
Öne Çıkar
Sayfa: 1
Giriş
Mesaj
  • Selamlar arkadaşlar telegram grubuma üye eklemek için bir script kullanmaya başladım ilk gün sorunsuz scripti çalıştırabildim ancak sonraki günlerde aşağıdaki hatayı almaya başladım.


    Kod

    Yığını:
    Task was destroyed but it is pending! task: <Task pending name='Task-48' coro=<Connection._send_loop() running at /Users/macbook/PycharmProjects/lcksdks/venv/lib/python3.8/site-packages/telethon/network/connection/connection.py:167> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x7ffeb6ed8580>()]>> Task was destroyed but it is pending! task: <Task pending name='Task-49' coro=<Connection._recv_loop() running at /Users/macbook/PycharmProjects/lcksdks/venv/lib/python3.8/site-packages/telethon/network/connection/connection.py:185> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x7ffeb6ed6c70>()]>> Task was destroyed but it is pending! task: <Task pending name='Task-50' coro=<MTProtoSender._send_loop() running at /Users/macbook/PycharmProjects/lcksdks/venv/lib/python3.8/site-packages/telethon/network/mtprotosender.py:442> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x7ffeb6ed6c40>()]>> Task was destroyed but it is pending! task: <Task pending name='Task-51' coro=<MTProtoSender._recv_loop() running at /Users/macbook/PycharmProjects/lcksdks/venv/lib/python3.8/site-packages/telethon/network/mtprotosender.py:485> wait_for=<Future pending cb=[<TaskWakeupMethWrapper object at 0x7ffeb6ed6d30>()]>>


    Acaba bu hatayı nasıl düzeltirim kaynak kod aşağıdaki gibi:

    Kod

    Yığını:
    import sys import csv import traceback import time import random import json from telethon.sync import TelegramClient #Client Module to Login from telethon.tl.functions.channels import JoinChannelRequest,InviteToChannelRequest from telethon.tl.functions.messages import GetDialogsRequest from telethon.tl.types import InputPeerEmpty, InputPeerChannel, InputPeerUser, InputPeerChat from telethon.errors.rpcerrorlist import PeerFloodError, UserPrivacyRestrictedError, UserAlreadyParticipantError from telethon.tl.functions.channels import InviteToChannelRequest from telethon.tl.functions.messages import AddChatUserRequest hesap_listesi=[] with open("credentials.json") as hesaplar: data = json.load(hesaplar) for h in data["hesaplar"]: hesap_listesi.append(h) for i in hesap_listesi : phone = i["phone"] api_id = api_hash = "" try: client = TelegramClient(phone, api_id, api_hash) client.connect() except: print("Could not create Telegram Client, Please check your Credentials in credentials.json file") exit() if not client.is_user_authorized () : client.send_code_request (i["phone"]) client.sign_in (phone, input ('Enter veryfication code: ')) print(hesap_listesi) start_index = 1100 for i in hesap_listesi: phone = i["phone"] api_id = 1807731 api_hash = "142d6bcef51361b90dcd5aeb8d8dc247" continue_script = False if len(sys.argv) == 5: g_index_scrapper = sys.argv[1] g_index_adder = sys.argv[2] mode = sys.argv[3] start_index = sys.argv[4] continue_script = True #Login & Verification Code try: client = TelegramClient(phone, api_id, api_hash) client.connect() except: print("Could not create Telegram Client, Please check your Credentials in credentials.json file") exit() for i in hesap_listesi: if not client.is_user_authorized(): client.send_code_request(i["phone"]) client.sign_in(phone, input('Enter veryfication code: ')) #Chat parameters chats = [] last_date = None chunk_size = 200 # No of latest chats to load groups = [] try: result = client(GetDialogsRequest( offset_date=last_date, offset_id=0, offset_peer=InputPeerEmpty(), limit=chunk_size, hash=0 )) chats.extend(result.chats) except: print("Unable to gather chats from server. Please Check Chat parameters.") exit() for chat in chats : try : if chat.megagroup == True : groups.append (chat) except : continue if len(groups) == 0: print("No Groups or Channels found.") exit() print('Available Groups and Channels:') i=1 for g in groups: print(str(i) + '- ' + g.title) i+=1 #User Inputs if not continue_script: target_group_scrapper = client.get_entity("https://t.me/indirimalarmi") target_group_adder = client.get_entity("https://t.me/apkmeydanii") client(JoinChannelRequest (target_group_scrapper)) time.sleep (2) client(JoinChannelRequest (target_group_adder)) mode = 2 if(mode not in [1,2]): sys.exit("Invalid Mode Selected. Please Try Again.") #Fetching participants from server all_participants = [] print('Fetching Members...') try: all_participants = client.get_participants(target_group_scrapper, aggressive=True) except: print("Unable to fetch participants of", target_group_scrapper) exit() if len(all_participants) == 0: print("No user found in", target_group_scrapper + '.', "Please check the group.") exit() try: target_group_entity_adder = InputPeerChannel(target_group_adder.id, target_group_adder.access_hash) isChannel = True except: target_group_entity_adder = InputPeerChat(target_group_adder.id) isChannel = False n = 0 user_added_count = 0 for i in range(start_index,len(all_participants)): user = all_participants[i] n += 1 if n % 50 == 0: time.sleep(900) try: print("Adding {}".format(user.id)) if mode == 1: try: if user.username != None: user_to_add = client.get_input_entity(user.username) except: continue elif mode == 2: user_to_add = InputPeerUser(user.id, user.access_hash) if isChannel: client(InviteToChannelRequest(target_group_entity_adder, [user_to_add])) else: client(InviteToChannelRequest(target_group_adder.id, user_to_add,fwd_limit=50)) user_added_count += 1 wait_time = random.randrange(60, 90) print("Waiting for",wait_time, "Seconds...") time.sleep(wait_time) except PeerFloodError: print("Getting Flood Error from telegram. Script is stopping now. Please try again after some time.") print("Run the following command after few hours to contiune where you left off:") print("python3 scrapper_and_adder.py", i) start_index = i continue_script = False break except UserPrivacyRestrictedError: print("The user's privacy settings do not allow you to do this. Skipping.") except UserAlreadyParticipantError: continue except: traceback.print_exc() print("Unexpected Error") continue print("Added:", user_added_count, "users to the group")


    Bu arada numaraları aşağıdaki json dosyasında yer alıyor api id ve hash aynı zaten


    Kod

    Yığını:
    { "hesaplar": [ {"phone": "+17602925311"}, {"phone": "+14422190473"}, {"phone": "+17608243569"} ] }







  • Bence telegram seni banlamış.

  • 
Sayfa: 1
- x
Bildirim
mesajınız kopyalandı (ctrl+v) yapıştırmak istediğiniz yere yapıştırabilirsiniz.