Телеграмм чат группы prophp7 страница 10932

parrot.ru

Рейтинг популярных групп и каналов

В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

PHP

1856 membersпожаловаться на группу

2020 August 11

ВУ

Валентин Удальцов... in PHP

на тему проекций и агрегатов...

ПРОЕКЦИИ могут быть не только left fold стрима, они могут так же на основе этого left fold кидать новые события. Например

projection
   .on(stream)
   .partitionBy(({customerId}) => customerId)
   .init(() => 0)
   .on('OrderConfirmed', (numberOfOrders, emit) => {
        numberOfOrders++
        if (numberOfOrders === 3) {
             emit(customerPurchasedThreeOrders())
             numberOfOrders = 0
        }
        return numberOfOrders
   }

А куда это новое событие пойдёт? В новый стрим или в текущий?

источник

15:34пожаловаться #1

DT

Dmitriy Tkachenko in PHP

в новый по идее

источник

15:35пожаловаться #2

DT

Dmitriy Tkachenko in PHP

похоже на stream api из кафки

источник

15:35пожаловаться #3

DT

Dmitriy Tkachenko in PHP

а она создает отдельный топик при обработке стрима

источник

15:35пожаловаться #4

ВУ

Валентин Удальцов... in PHP

Просто эта проекция неидемпотентна. При каждом запуске новый поток таких customerPurchasedThree

источник

15:36пожаловаться #5

ВУ

Валентин Удальцов... in PHP

Это выглядит как миграция стримов, когда внедряется новое событие, которого раньше не было)

источник

15:37пожаловаться #6

SP

Sergey Protko in PHP

Валентин Удальцов

А куда это новое событие пойдёт? В новый стрим или в текущий?

в новый стрим)

источник

15:38пожаловаться #7

DT

Dmitriy Tkachenko in PHP

ну если учесть что стрим аппенд онли

источник

15:38пожаловаться #8

DT

Dmitriy Tkachenko in PHP

то как ты в нужное место вставишь новое сообщение?

источник

15:39пожаловаться #9

SP

Sergey Protko in PHP

можешь глянуть как в eventstore сделано)

источник

15:39пожаловаться #10

SP

Sergey Protko in PHP

Валентин Удальцов

Просто эта проекция неидемпотентна. При каждом запуске новый поток таких customerPurchasedThree

мммм.... почему?

источник

15:39пожаловаться #11

SP

Sergey Protko in PHP

Валентин Удальцов

Просто эта проекция неидемпотентна. При каждом запуске новый поток таких customerPurchasedThree

у тебя считай "стрим вычисляемый по другому стриму"

источник

15:39пожаловаться #12

ВУ

Валентин Удальцов... in PHP

мммм.... почему?

Я понял, это просто динамическая формула нового стрима = новый стрим

источник

15:40пожаловаться #13

DT

Dmitriy Tkachenko in PHP

у нового стрима тоже есть свой оффсет, поэтому он знает что уже обработал

источник

15:40пожаловаться #14

SP

Sergey Protko in PHP

да, в концептах Грега Янга все ж упор больше на формирование стримов а не на "отправь email по событию"

источник

15:40пожаловаться #15

ВУ

Валентин Удальцов... in PHP

Дошло, спасибо)

источник

15:40пожаловаться #16

ВУ

Валентин Удальцов... in PHP

можешь глянуть как в eventstore сделано)

Ты его юзаешь на проекте, кстати?

источник

15:41пожаловаться #17

ВУ

Валентин Удальцов... in PHP

Я смотрел, мне очень понравилось. Ничего лишнего, всё как надо

источник

15:42пожаловаться #18

SP

Sergey Protko in PHP

неа... я тыкал его просто что бы проникнуться идеей

источник

15:42пожаловаться #19

SP

Sergey Protko in PHP

у меня свои велосипеды

источник

15:42пожаловаться #20