AS
И омг, там тоже пайплайны на пожмножестве джавы
Size: a a a
2020 October 17
DS
Надо написать пайплайн
нельзя это сделать в pipeline. Давай еще раз
В pipeline ты имеешь доступ только к текущему сообщению - все. Ты никак не можешь его сравинвать с другими сообщениями из потока
В pipeline ты имеешь доступ только к текущему сообщению - все. Ты никак не можешь его сравинвать с другими сообщениями из потока
AS
А ты продолжаешь в стену стучать, ну акей. Стучи, я в этом не участвую. Кому надо прочитают реализуют, возможности там есть для этого. Ты просто их не видишь в упор бггг
AS
Хинт, можно обмениваться переменными между пайплайнами!
DS
А ты продолжаешь в стену стучать, ну акей. Стучи, я в этом не участвую. Кому надо прочитают реализуют, возможности там есть для этого. Ты просто их не видишь в упор бггг
Ясно, пруфов не будет. В pipeline ты можешь сделать с текущим логом что угодно, можешь засылвать его в другие стримы, дропать, менять поля, парсить.
Но ты не можешь написать условие вида: дропни текущее сообщение, если 10 предыдущих в течении минуты были такими-же
Но ты не можешь написать условие вида: дропни текущее сообщение, если 10 предыдущих в течении минуты были такими-же
AS
Могу 😂 я же объяснил как уже
DS
Хинт, можно обмениваться переменными между пайплайнами!
так это не поможет. Лол.
AS
Не в коня опять корм
AS
Почему? Поможет
DS
Могу 😂 я же объяснил как уже
нет ты не объяснил. То что ты сказал - не будет работать, и я доказал почему
DS
Почему? Поможет
ну будет у тебя два pipeline, толку то. Каждый из них видит только текущее сообщение.
Ну сохранишь ты сообщение в первом pipleine в переменную.
Но сообщение по pipeline'ам проходит по очереди, в следущий pilpeline попадет это же сообщение, и переменную ты передашь с этим же сообщением.
Ну сохранишь ты сообщение в первом pipleine в переменную.
Но сообщение по pipeline'ам проходит по очереди, в следущий pilpeline попадет это же сообщение, и переменную ты передашь с этим же сообщением.
b
А цель какая в этом?
AS
Канеш будет, выдели регексп, которому матчится твоё текущее сообщение запиши его в кастомное поле, обработай это в другом пайплайне, которое уже понимает инкременты) единственный нюанс, тебе надо понять на каком условии начать распихивать сообщения по пайплайнам. Так и это тоже реализуется, прикинь)
AS
Да он пытается доказать, что я мудак
AS
Но это спорно
YB
Расстроился парень с момента, что базы в облаках могут быть сравнимы по скорости с локалхостом и понеслась.
DS
Канеш будет, выдели регексп, которому матчится твоё текущее сообщение запиши его в кастомное поле, обработай это в другом пайплайне, которое уже понимает инкременты) единственный нюанс, тебе надо понять на каком условии начать распихивать сообщения по пайплайнам. Так и это тоже реализуется, прикинь)
так откуда взять регекс лол. С чем регексить.
Вот у тебя два сообщения
1) {message: test}
2) {message: test}
1 сообщение попадает в первый pipleine, что ты там будешь регексить? ^.*$?
Вот у тебя два сообщения
1) {message: test}
2) {message: test}
1 сообщение попадает в первый pipleine, что ты там будешь регексить? ^.*$?
AS
Возможность все это реализовать есть, он её просто не понимает, а значит этого нельзя
DS
Возможность все это реализовать есть, он её просто не понимает, а значит этого нельзя
так ты же фигню говоришь. Без конкретики. А когда доходим до кода, сливаешься