PySimpleGui + Telegram 如何在单独的线程中上传文件？

Question

我正在尝试在线程中上传文件。所以稍后我可以添加带有进度条更新的回调等。

我尝试使用线程和 PySimpleGui 的 perform_long_operation 来做到这一点。 它不是这样工作的。

那么我该怎么做呢？可能我遗漏了一些关于 asyncio 使用的内容。

from pyrogram import Client
from time import sleep
import PySimpleGUI as sg
import asyncio
import random
import sys

api_id = 234242434
api_hash = '324423423'


sg.change_look_and_feel('DarkAmber')

layout = [
    [sg.Text('Password'), sg.InputText(password_char='*', key='password')],
    [sg.Text('', key='status', size=(20, 1))],
    [sg.Button('Submit'), sg.Button('Cancel')]
]

window = sg.Window('TG Send', layout, finalize=True)

client = None

def long_proc():
    client = Client('tg_send', api_id, api_hash)
    window['status'].update('connecting')
    client.connect()
    window['status'].update('started')

    done = False
    while True:
        if not done:
            print('Uploading file')
            window['status'].update('uploading')
            client.send_document('me', document='File.db')
            done = True
            print('Uploading done')
            window['status'].update('uploaded')
        else:
            sleep(1)
    

async def ui():
    while True:
        event, value = window.read(timeout=1)
        if event in (None, 'Cancel'):
            sys.exit()
        
        if event != '__TIMEOUT__':
            print(f"{event=} {value=}")
        
        if event == 'Submit':
            window.perform_long_operation(long_proc, '-FUNCTION COMPLETED-')

        await asyncio.sleep(0)


async def main():
    await asyncio.gather(
        asyncio.create_task(ui()),
        # asyncio.to_thread(long_proc),
        
    )
    

if __name__ == '__main__':
    asyncio.run(main())

Answer 1

以下信息仅适用于 PySimpleGUI 的代码，而不适用于 async 和 asyncio。

def long_proc():
    client = Client('tg_send', api_id, api_hash)
    window['status'].update('connecting')                   # Wrong call in thread
    client.connect()
    window['status'].update('started')                      # Wrong call in thread

    done = False
    while True:
        if not done:
            print('Uploading file')
            window['status'].update('uploading')            # Wrong call in thread
            client.send_document('me', document='File.db')
            done = True
            print('Uploading done')
            window['status'].update('uploaded')             # Wrong call in thread
        else:
            sleep(1)

执行长操作

此方法使用线程。这意味着您无法从您提供的函数进行任何 PySimpleGUI 调用，但一个函数 Window.write_event_value 除外。

相反，通过调用 window['status'].update(values['-STATUS-']) 来处理事件循环中的事件 -STATUS-。

def long_proc():
    client = Client('tg_send', api_id, api_hash)
    window.write_event_value('-STATUS-', 'connecting')
    client.connect()
    window.write_event_value('-STATUS-', 'started')

    done = False
    while True:
        if not done:
            print('Uploading file')
            window.write_event_value('-STATUS-', 'uploading')
            client.send_document('me', document='File.db')
            done = True
            print('Uploading done')
            window.write_event_value('-STATUS-', 'uploaded')
        else:
            sleep(1)