Даниил Рыжов

import os
# import time

import requests
from openpyxl import load_workbook
from dotenv import load_dotenv

API_URL = 'https://api.edenai.run/v2/audio/text_to_speech'
HEADERS = {"Authorization": f"Bearer {os.getenv('API_KEY')}"}
DEFAULT_LANGUAGE = 'ru-RU'
DEFAULT_OPTION = 'MALE'
DEFAULT_VOICE = 'ru-RU_Alexei Syomin'


def convert_text_to_speech(row_number: int, _id: int, text: str):
    payload = {
        'providers': 'lovoai',
        'language': DEFAULT_LANGUAGE,
        'option': DEFAULT_OPTION,
        'lovoai': DEFAULT_VOICE,
        'text': text
    }

    response = requests.post(API_URL, json=payload, headers=HEADERS)
    result = response.json()

    audio_url = result.get('lovoai', {}).get('audio_resource_url')
    if audio_url:
        audio_content = requests.get(audio_url).content
        with open(f'row_{row_number}_ID_{_id}.ogg', 'wb') as audio_file:
            audio_file.write(audio_content)


def main(file_name: str):
    book = load_workbook(file_name)
    sheet = book.active
    for row in range(2, sheet.max_row + 1):
        _id = sheet[row][0].value
        text = sheet[row][1].value
        convert_text_to_speech(row, _id, text)

        # Установите задержку, если имеется ограничение на кол-во запросов в секунду
        # time.sleep(3)


if __name__ == '__main__':
    load_dotenv()
    main('name.xlsx')

Примеры proxy url:

socks5://user:password@host:port
http://host:port
https://host:port
http://user:password@host

@dp.message_handler(commands=['some_command'])
async def some_handler(message: Message):
    text = 'Текст для отправки '
    DELAY = 10
    _loop = asyncio.get_running_loop()
    _loop.call_later(DELAY, func, message.from_user.id, text)

async def func(chat_id, text):
    await dp.bot.send_message(chat_id, text)

if message.text.isdigit():
    print('ok')
else:
    print('Это не число')

if __name__ == '__main__':
    loop = asyncio.new_event_loop()
    scheduler = AsyncIOScheduler(event_loop=loop)
    scheduler.add_job(main, 'interval', seconds=3)
    scheduler.start()
    try:
        loop.run_forever()
    except (KeyboardInterrupt, SystemExit):
        pass

try:
    asyncio.get_event_loop().run_forever()
except (KeyboardInterrupt, SystemExit):
    pass

import asyncio
import ssl


ctx = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT)
# the root CA path is dependent on your system. 
ctx.load_verify_locations(cafile='/etc/ssl/cert.pem')

async def test_example(loop):
    pool = await aiomysql.create_pool(host='', port=3306, user='redst', password='',
                                  db='aiodb', loop=loop, ssl=ctx)

photo_data = await db.get_file_info(f'{files_dir}file_name.png')
if photo_data is None:
    media = types.InputFile(f'{files_dir}file_name.png')
    msg = await dp.bot.send_photo(chat_id=message.chat.id, photo=media)
    full_size_photo_id = msg['photo'][-1]['file_id']
    await db.add_file_info(full_size_photo_id)
else:
    await dp.bot.send_photo(chat_id=message.chat.id, photo=photo_data)

if adm_spis == spisbtns[0]:
    users = db.db_all()
    db_schet = len(users)
    users_list = {}
    text_message = ''
    for user in users:
        id = user[0]
        username = user[1]
        user_id = user[2]
        number = user[3]
        subscription = user[4]
        admi = user[5]
        blocked = user[6]
        ban = user[7]
        text_message += f'<b>ID: </b><code>{id}</code>\n<b>USERNAME: </b><code>{username}</code>\n<b>USER_ID: </b><code>{user_id}</code>\n<b>NUMBER: </b><code>{number}</code>\n<b>SUBSCRIPTION: </b><code>{subscription}</code>\n<b>BLOCKED: </b><code>{blocked}</code>\n<b>BAN: </b><code>{ban}</code>\n\n'

    await msg.answer(f'<b>ВСЯ БАЗА ДАННЫХ </b>\n\n<i>Всего в базе: </i><code>{db_schet}</code>\n\n{text_message}', parse_mode='html')