БГ
@wrongnull, почитай статью и подумай прав ли ты был (спойлер: не прав)
Size: a a a
2021 January 04
P
@wrongnull, почитай статью и подумай прав ли ты был (спойлер: не прав)
<Ч
Специально взял такую задачу под которую в питон и принесли компрех и удивляешься, что компрех быстрее фильтра?)
P
Специально взял такую задачу под которую в питон и принесли компрех и удивляешься, что компрех быстрее фильтра?)
Я как бы изначально этот пример и приводил в предложении выше
P
Потому и сказал, что фп - это не всегда быстро или не всегда быстрее встроенных синтаксических конструкций
k
Суть: ебусь с алембиком, пытаюсь, чтобы оно само миграции делало
Проблема: импорт решил коньки откинуть, хотя по факту все делаю заебисб, даже запуск скрипта идет с директории, откуда у меня есть только два пути, либо в
Проблема: импорт решил коньки откинуть, хотя по факту все делаю заебисб, даже запуск скрипта идет с директории, откуда у меня есть только два пути, либо в
app, либо в alembic<Ч
Суть: ебусь с алембиком, пытаюсь, чтобы оно само миграции делало
Проблема: импорт решил коньки откинуть, хотя по факту все делаю заебисб, даже запуск скрипта идет с директории, откуда у меня есть только два пути, либо в
Проблема: импорт решил коньки откинуть, хотя по факту все делаю заебисб, даже запуск скрипта идет с директории, откуда у меня есть только два пути, либо в
app, либо в alembicИз какой папки и какой командой запускаешь?
MD
Господа, интересует такой вопрос, сам я нодер, но появилась надобность написать сервис на петончике, суть такова: начал дайвить в async/await, и если, допустим, я хочу слушать вечно pub/sub редиса мне, соответстенно, надо юзать
loop.run_forever? какой бест практис? Заранее спасибоk
Из какой папки и какой командой запускаешь?
запускаю в
Вот структура самого проекта
project команду:alembic revision --autogenerate -m "мессаге"
Вот структура самого проекта
project/
alembic/
app/
models/
__init__.py
А
Господа, интересует такой вопрос, сам я нодер, но появилась надобность написать сервис на петончике, суть такова: начал дайвить в async/await, и если, допустим, я хочу слушать вечно pub/sub редиса мне, соответстенно, надо юзать
loop.run_forever? какой бест практис? Заранее спасибоЧерез какую либу редис используешь? Aioredis?
MD
Через какую либу редис используешь? Aioredis?
ее
VA
Господа, интересует такой вопрос, сам я нодер, но появилась надобность написать сервис на петончике, суть такова: начал дайвить в async/await, и если, допустим, я хочу слушать вечно pub/sub редиса мне, соответстенно, надо юзать
loop.run_forever? какой бест практис? Заранее спасибоКак вариант создать корутину, внутри которой while True:
И там через пару миллисекунд запрос с редиса. Запустить её в фоне.
Или посмотреть в сторону aioredis, может там уже готовое для этого есть.
И там через пару миллисекунд запрос с редиса. Запустить её в фоне.
Или посмотреть в сторону aioredis, может там уже готовое для этого есть.
MD
просто я так понимаю, что скрипт тухнет сразу как получит с паблиш канала инфу, а мне, собсна, надо слушать паблиш канал пока сервис живет
MD
Как вариант создать корутину, внутри которой while True:
И там через пару миллисекунд запрос с редиса. Запустить её в фоне.
Или посмотреть в сторону aioredis, может там уже готовое для этого есть.
И там через пару миллисекунд запрос с редиса. Запустить её в фоне.
Или посмотреть в сторону aioredis, может там уже готовое для этого есть.
да, я aioredis и юзаю =)
VA
да, я aioredis и юзаю =)
А
Господа, интересует такой вопрос, сам я нодер, но появилась надобность написать сервис на петончике, суть такова: начал дайвить в async/await, и если, допустим, я хочу слушать вечно pub/sub редиса мне, соответстенно, надо юзать
loop.run_forever? какой бест практис? Заранее спасибоПросто, обычно для высокоуровневых приложений лупы лучше ну трогать, а просто запускать
С aioredis не знаком, но по-хорошему всё сама должна делать
asyncio.run(main())С aioredis не знаком, но по-хорошему всё сама должна делать
MD
import asyncio
import aioredis
async def main():
redis = await aioredis.create_redis_pool("redis://localhost")
ch1, ch2 = await redis.subscribe("channel:1", "channel:2")
asyncio.run(main())
ну вот, я запускаю такой код, и он по идее, не должен завершатся, так как идет субскрайб, а значит идет прослушка канала, но он завершается
MD
может я чего то не понимаю, сори :))
А
import asyncio
import aioredis
async def main():
redis = await aioredis.create_redis_pool("redis://localhost")
ch1, ch2 = await redis.subscribe("channel:1", "channel:2")
asyncio.run(main())
ну вот, я запускаю такой код, и он по идее, не должен завершатся, так как идет субскрайб, а значит идет прослушка канала, но он завершается
Там же в примере дальше:
async for message in channel.iter():
print("Got message:", message)<Ч
import asyncio
import aioredis
async def main():
redis = await aioredis.create_redis_pool("redis://localhost")
ch1, ch2 = await redis.subscribe("channel:1", "channel:2")
asyncio.run(main())
ну вот, я запускаю такой код, и он по идее, не должен завершатся, так как идет субскрайб, а значит идет прослушка канала, но он завершается
Субскрайб точно бесконечная операция?