IK
А смысл? Если у вас значения константные, зачем делать двойную работу и лишний раз дёргать базу?
Потому что мне нужно гарантировать что джоб в очередь отправил а не забрал таску на 7 дней и не донес
Size: a a a
2020 November 13
SD
А очередь транзакционная?
IK
А очередь транзакционная?
нет, считай там кафка. то но сообщения идемпотентные будут
IK
то есть я понимаю что туда может 2 раза улететь, но будем считать что второе пропустит получатель
SD
то есть я понимаю что туда может 2 раза улететь, но будем считать что второе пропустит получатель
А в кафку синхронно пишите?
IK
А в кафку синхронно пишите?
смотри, это пример кода на уровне "паттерн" считай что метод вызваный q гарантировано положит в очередь синхронно
SD
👍 Пробуйте
IK
это не продакшн код, это я локально размышляю
SD
это не продакшн код, это я локально размышляю
Ну смотри, если вызов там синхронный, то ты точно будешь знать положено сообщение или нет, и если не положено, то можешь снять лок. При нормальной эксплуатации это потребует меньше дергать базу. Я тоже размышляю и не претендую на истину в последней инстанции )))
IK
то есть я не против альтернативных вариантов) но че то мне пока никто не отвечает как борется с dual-write
SD
то есть я не против альтернативных вариантов) но че то мне пока никто не отвечает как борется с dual-write
Не писать в кафку? )))
IK
Ну смотри, если вызов там синхронный, то ты точно будешь знать положено сообщение или нет, и если не положено, то можешь снять лок. При нормальной эксплуатации это потребует меньше дергать базу. Я тоже размышляю и не претендую на истину в последней инстанции )))
не, это ты говоришь если очередь ошиблась, а если свет вырубили не сможешь откатить
IK
Не писать в кафку? )))
ну ок, пускай там не кафка а БД)
i
не, это ты говоришь если очередь ошиблась, а если свет вырубили не сможешь откатить
+
SD
не, это ты говоришь если очередь ошиблась, а если свет вырубили не сможешь откатить
Нужно посмотреть как в этом случае отработает транзакция. Я не помню точно где она закроется. Я сейчас про транзакцию в которой выполняется чтение тасков и первоначальный лок.
IK
Нужно посмотреть как в этом случае отработает транзакция. Я не помню точно где она закроется. Я сейчас про транзакцию в которой выполняется чтение тасков и первоначальный лок.
после взятия лока на 3 секунды - все, камунда закоммитила что это залочено
SD
Ну тогда выглядит оправдано. 👍
IK
спс) а так же жду еще мнений
SD
Вы только учтите, что там не в лоб задача решается. Вам нужно где-то сохранить объект deffered result после запуска процесса, а когда процесс завершится заинжектить в него получившийся результат.