Пишу бота (aiogram, везде используется async). Для простоты получения/обработки данных с быстрой возможностью редактирования я решил написать web-api. Написал на expressjs (выводит данные из БД), дописал на php легкую веб морду (вносит данные в БД).
В настоящий момент api полностью работает, возвращает данные как и положено.
Появилась необходимость ограничить круг пользователей, после чего в это же API я решил добавить и id telegram аккаунтов в новую таблицу, которые могут запускать бота (довольно простое решение). Но я столкнулся с тем, что ни одну библиотеку (aiohttp/httpx) не могу настроить через async.
Имею следующую структуру:
Класс, через который я хотел обращаться к API (не работает, причину понять не могу)
class access():
async def getdata(path):
client = httpx.AsyncClient()
async with client.stream('GET', path) as response:
for record in response:
if record["userid"] == userid:
return userid
Пример класса с функцией, где подключаю код выше:
class userlist():
async def user_all(user_id):
if user_id in await access.getdata("http://localhost/users"):
return True
else:
return False
Если просто стучусь через браузер на http://localhost/users
то получаю все нужные мне id в формате [{"userid":12345678},{"userid":12345679}], Content-Type: application/json; charset=utf-8
, т.е. все как положено.
Если что, на питоне пишу не долго, поэтому прошу прощения за возможные ошибки, но литературу/документации штудировал пол дня.