Как обрабатывать транзакции в ParallelFlux? ⇐ JAVA

[Anonymous]

У нас есть очень перерабатывающий конвейер для тяжелых флюсов. Чтобы ускорить его, мы используем параллельный поток. Но теперь проблема в том, что все ожидает подключения к базе данных, и оно все еще медленное. Весь конвейер в настоящее время находится в рамках одной большой транзакции. Как обрабатывать параллельныйFlux с транзакциями, чтобы вставки в БД не слишком сильно блокировали друг друга? База данных — Postgresql, мы используем r2dbc. Или еще лучше, если бы разные параллельные ветви использовали разные соединения.

Подробнее здесь: https://stackoverflow.com/questions/792 ... rallelflux