В общем, насчет моего вопроса по кешированию — мой вариант ответа пока таков (для сферических сверх-нагрузок в вакууме): на каждом из воркеров держать в памяти небольшой кольцевой буфер этих самых "последних продуктов", которые обновляются при записи продукта с этого воркера. В этом буфере также держится таймстамп момента обновления. Затем каждые, скажем, 1 секунду (тут надо подумать) эти воркеры "сбрасывают кеш" — все шлют его на одну машину, которая делает merge sort / limit, и уже результат пихает в Redis.

Естественно, это всё при сферических сверх-нагрузках в вакууме.

#otggoz

add comment recommend bookmark subscribe