IA
ну вы поняли
Size: a a a
2019 March 01
ŹR
Так это же пиздец
ŹR
Enum.to_list загрузит все в память
IA
ну вот я бы лучше через оффсеты пошел с рекурсией
IA
там как то проще/ хз как этот stream в Repo работает
FM
стрим работает через курсор
NP
q
uery = from(n in Foo, select: n, preload: [bar: :baz])
stream = Repo.stream(query, max_rows: 1)
Repo.transaction(fn() ->
Enum.to_list(stream)
|> your_method_with_row()
…нет разницы (
NP
Enum.to_list(stream) уже возвращает все
FM
stream |> Stream.map(fn batch -> … end)FM
ну и там потом его ещё запустить надо. либо
stream |> Stream.map(fn batch -> … end) |> Enum.to_list(), если хочешь все результаты получить списком, либо stream |> Stream.map(fn batch -> … end) |> Stream.run(), если только сайд эффект нуженŹR
Откуда он возьмет batch_size?
ŹR
Брать по одной записи, даже через курсор - не выглядит эффективно
ŹR
А, ну ясно откуда
ŹR
Он при первом резолве скачает сразу 500 в память, но вернет только одну
ŹR
Только не fn batch а fn record тогда
ŹR
И все это внутри транзакции
NP
Спасибо :)
ŹR
И max_rows: 1 убери
ŹR
А то смысла нету в таких курсорах)