Возможно ли создать асинхронную функцию чтобы отправлять в неё данные постепенно без await?

Question

[RINCODE]

Возможно ли создать асинхронную функцию чтобы отправлять в неё данные постепенно без await?
т.е.

async def ff(a):
print("первый a")
print("второй a")

def g():
ff(1)
ff(2)

g()

При этом мне в def g нельзя юзать await т.к. я не могу сделать этот метод асинхронным. Буду рад помощи, нашёл что то тип second_data = yield но не получилось сделать чтобы def ff(a): был ассинхронным

Answer 1

[Vindicar]

asyncio.Queue в помощь. Чтобы синхронно помещать туда элементы, или используй put_nowait(), или выкручивайся с вызовом put() через create_task().

Но у меня прямой вопрос: а как ты, собственно, собираешься выполнять синхронную g() в асинхронной программе? Потому что если через потоки, то про совет выше можешь забыть.

Comments

[RINCODE]

В общем я пытаюсь скомбинировать 2 либы telebot (бот тг) и pyrogram, в методе (функции) pyrogram он требует ассинхроность для вызова функций и в этом проблема

[Vindicar]

RINCODE, ну комбинировать два разных фреймворка для ботов - уже плохая идея. А уж синхронный с асинхронным... Выбери тот, на котором нужные фичи есть, и пиши на нём.

[RINCODE]

Vindicar, да мне поздно сообщили, звувз дорвботвть бота

Answer 2

[Everything_is_bad]

вариант

async def ff(a):
    print("первый a")
    print("второй a")

async def hh():
    await ff(1)
    await ff(2)

def g():
    asyncio.run(hh())

g()

хотя больше похоже что ты просто не понимаешь как работает asyncio

Comments

[RINCODE]

Я не могу использовать asyncio.run т.к. def start_bot():
bot.polling(none_stop=True) запущено через него и выдает ошибку

[Everything_is_bad]

RINCODE,

хотя больше похоже что ты просто не понимаешь как работает asyncio

[RINCODE]

В общем я пытаюсь скомбинировать 2 либы telebot (бот тг) и pyrogram, в методе (функции) pyrogram он требует ассинхроность для вызова функций и в этом проблема

[Everything_is_bad]

RINCODE, значит ты можешь запускать async, давай читай доки как бота, так и питона, ну и вообще разбирайся как он работает.

[RINCODE]

Everything_is_bad, не могу т.к. юзаю его здесь

@bot.message_handler(commands=['addaccount'])
def addaccount(message):

Он не позволяет создать ассинхронную функцию

[Everything_is_bad]

RINCODE, telebot умеет в async, начни с этого

[RINCODE]

Everything_is_bad,

[Everything_is_bad]

RINCODE, ну и живи в 2020 году, ты способен просто открыть текущие доки и начать их читать, а?

[shurshur]

RINCODE, не надо верить любым сказкам, которые рассказывает нейросеть. В современной версии телебота есть класс AsyncTelebot, который как раз асинхронный.

Однако разбираться потом, что там сломается при замене класса на асинхронный, может быть не очень просто. И вполне возможно окажется, что проще переписать всё на более развитую асинхронную библиотеку aiogram либо даже на сам pyrogram, раз уж он тоже предполагается к использованию.