Те вопрос привычки во многом

ping -t

平

Привет, всем
Помогите с фильтрацией списка, плз

исходный:
[
%{value1: 100, value2: 0, value3: 0, date: «2018-05-01 00:00:00»},
%{value1: 100, value2: 10, value3: 0, date: «2018-05-01 00:00:01»},
%{value1: 101, value2: 10, value3: 0, date: «2018-05-01 00:00:02»},
%{value1: 101, value2: 15, value3: 0, date: «2018-05-01 01:00:03»},
%{value1: 101, value2: 15, value3: 1000, date: «2018-05-01 02:00:04»},
%{value1: 103, value2: 15, value3: 1000, date: «2018-05-01 05:00:05»},
%{value1: 103, value2: 15, value3: 1001, date: «2018-05-01 05:00:06»},
%{value1: 104, value2: 15, value3: 1001, date: «2018-05-01 06:00:07»},
%{value1: 104, value2: 17, value3: 1001, date: «2018-05-01 06:00:08»},
%{value1: 107, value2: 17, value3: 1001, date: «2018-05-01 06:00:09»}
]

Нужно чтоб в нем остались последнии записи из каждого часа

[
%{value1: 101, value2: 10, value3: 0, date: «2018-05-01 00:00:02»},
%{value1: 101, value2: 15, value3: 0, date: «2018-05-01 01:00:03»},
%{value1: 101, value2: 15, value3: 1000, date: «2018-05-01 02:00:04»},
%{value1: 103, value2: 15, value3: 1001, date: «2018-05-01 05:00:06»},
%{value1: 107, value2: 17, value3: 1001, date: «2018-05-01 06:00:09»}
]

Привет, можно решить с помощью Enum.group_by, Enum.map, Enum.sort  и List.last

в лоб - Enum.group_by с отсечением минут, потом в каждой отдельной пачке сортируешь по date и максимум

как и сказали выше)

ок, буду пробовать

list
|> Enum.reduce(%{}, fn %{date: date} = map, acc ->
  {:ok, time, _} = DateTime.from_iso8601(date <> "Z")
  Map.put(acc, %{time | minute: 0, second: 0}, map)
end)
|> Map.values()

не?

предполагается, что список отсортирован. если нет, но put надо в кейс со сравнением обернуть.

да, то что нужно, спасибо

Господа подскажите, где почитать про дебаг в фениксе праем?

Вероятно я хочу странного, но можно ли в связке GenStage Producer -> Consumer заставить потребителя сделать sleep на некоторое время, если у продюсера кончились данные для обработки? я пробовал так:
в продюсере в handle_demand(demand, []) если выборка данных пустая, то возвращаю {:noreply, [], []}.
в воркере такое добавил:

  def handle_events([], _from, db_pid) do
    Logger.info "next_pack empty, wait"
    :timer.sleep 5_000
    {:noreply, [], db_pid}
  end

Но на деле продюсер возвращает :noreply, и потом ничего не происходит, как будто в воркер и не попадает

[Перевод] Можно ли осознанно отказаться от функционального программирования? https://u.tmtm.ru/MXNpP

они там совсем ебобо?))

  def handle_events([], _from, db_pid) do
    Logger.info "next_pack empty, wait"
    :timer.sleep 5_000
    {:noreply, [], db_pid}
  end

зачем?

Прочитай внимательно статью

Чтобы типа ограничить частоту походов продюсера в базу. Да, знаю что такое можно сделать с помощью генсервера

  def handle_events([], _from, db_pid) do
    Logger.info "next_pack empty, wait"
    :timer.sleep 5_000
    {:noreply, [], db_pid}
  end

В таком подходе на сколько я помню нужно ставить таймер на повторный запрос продюсеру на получение данных, потому что он сам тебе не пихнет их

Руками отправить handle_call?