Как использовать PipelineDB для автоматизации обновления медленно изменяющейся таблицы измерений? - PullRequest
Новая
       16

Как использовать PipelineDB для автоматизации обновления медленно изменяющейся таблицы измерений?

0 голосов
/ 24 марта 2019

Может PipelineDB использоваться для автоматизации обновления Медленно изменяющейся таблицы размеров (тип 2) ?

Конкретный пример:

СкажитеУ меня есть таблица с именем ProductOfferHistory, в которой отслеживаются товарные предложения для определенной комбинации товаров / магазинов / дат.(то есть: цена, isAvail, storeId, productId, fromDt, toDt).Если приходит новое OfferEvent (productId, StoreId, price, isAvail, dt), должно произойти одно из 2:

1) price / isAvail совпадает с последней записанной записью ProductOfferHistory для productId / storeId.В этом случае: пропустите

2) цена / isAvail отличается от последней записанной записи ProductOfferHistory для productId / storeId.В этом случае:

  • установите для toDT указанной последней записи значение event.dt
  • создайте новую запись: price / isAvail / storeId / productId / fromDt = event.dt

Возможно ли использовать PipelineDB, чтобы OfferEvents входили в качестве потока, и обновляли ProductOfferHistory с помощью вышеописанной логики?

...