так то оно да, просто переделывать не хо )

а если использовать limit offset

ну этот вариант и предложен

паралельно запускаешь выполнения в нескольких процессах и все.

с таймаутом там скорее всего выпадает сам процесс. ему его можно как-то подкрутить

если прямне хочется переделывать

👍

парне сори за офтоп но у кого какой пет проджект на эликсире?

где ?

там не о вашей проблеме речь шла.

как запрос делается в бд ?

у меня друг делает пет проект. правда на ерланге. замену Фабрикатору. для управления персоналом. называется "Узурпатор"

спасибо

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

да думаю надо параллелить в любом случае, дофига строк

я почему-то думал, что это
stream = Repo.stream(from p in Ips)
{:ok, ips} = Repo.transaction(fn() -> Enum.to_list(stream)  end)
параллелит

хотя тоже странно, на 300к строк норм работает, на 3кк уже падает по таймауту от базы

надо смотреть. поидее не должен

а получаю

** (DBConnection.ConnectionError) tcp recv: closed
   (db_connection) lib/db_connection.ex:1483: DBConnection.fetch/6
   (elixir) lib/stream.ex:1285: Stream.do_resource/5
   (elixir) lib/stream.ex:1433: Enumerable.Stream.do_each/4
   (elixir) lib/stream.ex:806: Stream.do_transform/8
   (elixir) lib/enum.ex:1847: Enum.reverse/1
   (elixir) lib/enum.ex:2596: Enum.to_list/1
   (ecto) lib/ecto/adapters/sql.ex:576: anonymous fn/3 in Ecto.Adapters.SQL.do_transaction/3
   (db_connection) lib/db_connection.ex:1275: DBConnection.transaction_run/4