Size: a a a

2020 April 21

R

Ruslan in ctodailychat
Igor V
как собиратель метрик кафка не подходит, а как очередь - ну it depends, а в вашем случае все равно нужен оркестратор который «пробежится по строкам и обновит базу/сбегает в ещё один сервис»
а что имеется в виду под "собиратель метрик" тут? чтобы она сама куда-то ходила? мы довольно успешно используем кафку, как инструмент, через который события вытекают в наш data warehouse
источник

IV

Igor V in ctodailychat
хороший вопрос, мне под «собиратель метрик» представляется аналог cloudwatch
источник

IV

Igor V in ctodailychat
Andrey
Как очередь сообщений, собиратель метрик...
что понимаете под собиратель метрик?
источник

A

Andrey in ctodailychat
Надо понять сколько времени занимает обработка одного файла
источник

A

Andrey in ctodailychat
Сколько строк обработали с ошибками/сколько без
источник

a

agathis in ctodailychat
Andrey
Но я сам думаю зачем
Вместо одного большого процесса "прочитать файл, и по каждой строке сходить в БД" появляются асинхронные "прочитать файл" и "по каждому сообщению сходить в БД"
источник

IV

Igor V in ctodailychat
ага, значит CW like
источник

A

Andrey in ctodailychat
Igor V
как собиратель метрик кафка не подходит, а как очередь - ну it depends, а в вашем случае все равно нужен оркестратор который «пробежится по строкам и обновит базу/сбегает в ещё один сервис»
Я думал сделать так: s3 на новый файл дергает лямбду, она ставить в очередь событие с путём к файлу, первая тачка проходит по строкам и генерирует (количество строк)*событие с данными одной строки и вторая тачка процессит по одной....
источник

A

Andrey in ctodailychat
agathis
Вместо одного большого процесса "прочитать файл, и по каждой строке сходить в БД" появляются асинхронные "прочитать файл" и "по каждому сообщению сходить в БД"
Да
источник

A

Andrey in ctodailychat
Igor V
ага, значит CW like
Можно расшифровать CW?
источник

IV

Igor V in ctodailychat
CloudWatch
источник

A

Andrey in ctodailychat
Igor V
CloudWatch
Это что-то из aws?
источник

A

Andrey in ctodailychat
Я бы сделал на sqs +lambda...
источник

IV

Igor V in ctodailychat
Andrey
Я думал сделать так: s3 на новый файл дергает лямбду, она ставить в очередь событие с путём к файлу, первая тачка проходит по строкам и генерирует (количество строк)*событие с данными одной строки и вторая тачка процессит по одной....
это все сложно S3 Notification можно положить сразу в SQS без лямбд
источник

A

Andrey in ctodailychat
Igor V
это все сложно S3 Notification можно положить сразу в SQS без лямбд
Да, и Kafka sqs connector...
источник

IV

Igor V in ctodailychat
но вам все равно нужна оркестрация
источник

IV

Igor V in ctodailychat
может сразу смотреть в сторону Airflow или в крайнем случае на AWS Step Functions?
источник

A

Andrey in ctodailychat
Igor V
может сразу смотреть в сторону Airflow или в крайнем случае на AWS Step Functions?
Да я говорил про airflow , но мне сказали копай кафку...
источник

IV

Igor V in ctodailychat
лол
источник

A

Andrey in ctodailychat
Вот и я не понимаю или у меня кукуха от самоизоляции едет
источник