@gogolang
Alexey24.05.2018
20:27:48
20:27:48
Vadiimmm:-)))
Alexey24.05.2018
20:33:30
20:33:30
а насколько корректно такой счетчик RPS?
var counter int32
ticker := time.NewTicker(time.Second * 1)
go func() {
for range ticker.C {
fmt.Println("RPS", atomic.LoadInt32(&counter))
atomic.StoreInt32(&counter, 0)
}
}()
потом в лупе просто atomic.AddInt32(&counter, 1)
в конце каждой итерации
Я бы воркера сделал, у которого селектом обнуление по таймеру и по каналу счётчикОно хоть и на тех же атомиках, но более читаемо, как мне кажется
Google
Александр24.05.2018
20:35:24
20:35:24
эм?
у меня и так "воркер"
раз в секунду просыпается и обнуляет выводя статистику
но я сделал раз в 10 секунд и делю число на 10
тогда более усредненно выходит
Alexey24.05.2018
20:37:23
20:37:23
Не, ну тоже вариант. Я своё видение сказал.
Александр24.05.2018
20:37:33
20:37:33
я несколько не понял виденье
Alexey24.05.2018
20:40:33
20:40:33
Горутина с запущенным таймером и селект каналов таймера и канала счётчика по таймеру обнуление и вывод, по каналу счётчика добавление. Медленнее, да.
Александр24.05.2018
20:44:30
20:44:30
а что это даст?
вообще то
for range ticker.C {
это мы читаем канал
еще один канал для счетчика?
GoogleАлександр24.05.2018
20:45:57
20:45:57
какой смысл
Alexey24.05.2018
20:49:06
20:49:06
В скорости никакой
У тебя хороший вариант, только добавление счётчика в функцию обернуть
Ну и старт
И структуру из этого для красоты
Nik24.05.2018
23:29:56
23:29:56
Offtop - golangShow в России ни у кого не качается?
Мерлин25.05.2018
04:29:43
04:29:43
Александр25.05.2018
04:45:09
04:45:09
error calling MarshalJSON for type *json.RawMessage: invalid character 'a' looking for beginning of value
вот что за бред то
даже по рекомендации сделал на всякий случай как поинтер
payload := json.RawMessage("i test")
model.Payload = &payload
Payload *json.RawMessage json:"payload"
бред полный бред
Alexei25.05.2018
04:49:04
04:49:04
json.RawMessage это же []byte вроде, который должен выглядеть, как строковой json
Tom25.05.2018
07:25:27
07:25:27
Кто-нибудь забирает датку из Modbus протокола гошкой? Если да, к вам вопрос: писали что-то своё или используете готовый пакет(какой?)?
Спасибо.
Google
Petr25.05.2018
07:31:15
07:31:15
Это вы цже наняли специалиста и решили его проверить?
Tom25.05.2018
07:31:33
07:31:33
Ват?
Mykyta25.05.2018
08:52:11
08:52:11
а насколько корректно такой счетчик RPS?
var counter int32
ticker := time.NewTicker(time.Second * 1)
go func() {
for range ticker.C {
fmt.Println("RPS", atomic.LoadInt32(&counter))
atomic.StoreInt32(&counter, 0)
}
}()
потом в лупе просто atomic.AddInt32(&counter, 1)
в конце каждой итерации
вполне может быть такое, что тикер не тикнет в заданное время из-за планировщикаAlexey25.05.2018
11:20:22
11:20:22
Daniel25.05.2018
11:20:59
11:20:59
именно такое - нет
теоретически - может, практически - скорее, мы вычитывать не будем успевать
Alexey25.05.2018
11:28:41
11:28:41
теоретически - может, практически - скорее, мы вычитывать не будем успевать
Так там же канал, из него может уйти в космос?
Nazary25.05.2018
11:56:39
11:56:39
Ребят
Мб кто шарит Фейсбуке апи
Там же нельзя получить айди пользователей которые лайкнул какой-то чужой пост?
Андрей25.05.2018
12:04:04
12:04:04
Йоу. Вот есть у меня база, в которой хранятся некие евенты с какими-то данными, и я хочу скормить их некой либе, которая мне сможет помочь удобненько работать с выборкой эвентов как с time series — ну там временной шаг менять с соответствующим мёржингом значений и всё такое. Есть в го чо?
Daniel25.05.2018
12:05:18
12:05:18
именно в го? как в языке?
Андрей25.05.2018
12:05:26
12:05:26
ну да
но, альтернативные варинаты тоже рассматриваются
есть кликхаус, есть админка, есть евенты, есть апишка между первым и вторым, вот надо евенты для админки как следует покрутить
а то ручками всё это складывать утомительно
Илья25.05.2018
12:07:15
12:07:15
вы к нам откуда? что за языки такие с time series
Андрей25.05.2018
12:08:22
12:08:22
вот в педоне можно pandas заюзать
Alexander25.05.2018
12:08:34
12:08:34
prometheus не подойдет?
Андрей25.05.2018
12:09:06
12:09:06
не, не то, тут всё кастомное
GoogleAlexey25.05.2018
12:09:27
12:09:27
https://www.influxdata.com/time-series-platform/influxdb/
Илья25.05.2018
12:09:54
12:09:54
у человека все уже лежит в кликхаусе
Андрей25.05.2018
12:12:01
12:12:01
инфлюкс не вариант, только вот от него избавились и в кликхаус всё засунули, но щас не об этом
Alexey25.05.2018
12:12:31
12:12:31
у человека все уже лежит в кликхаусе
Так там куча функций для обработки, что ещё тогда нужно? Графану подключить к клику?Илья25.05.2018
12:13:37
12:13:37
я вообще не понял, что человеку нужно, но, предполагаю что golang data frames analysis приведет юного гофера куда-то
AdminERROR: S client not available
Андрей25.05.2018
12:14:17
12:14:17
ну вот, ещё и юным назвали
Илья25.05.2018
12:18:05
12:18:05
так и не понятно, вам что нужно? разбивать блоки данных на временные промежутки? стастику собирать? или что? pandas - это про статистику, вроде как
если статистику, то посмотрите gonum, вроде бы его хвалили
The25.05.2018
12:20:15
12:20:15
человек, видимо, хочет обертку, чтобы упростить выборки из CH
Tom25.05.2018
12:20:52
12:20:52
Человек пока не рассказал что хочет: предобработку, пайплайн, ML. Хз
Андрей25.05.2018
12:20:58
12:20:58
так и не понятно, вам что нужно? разбивать блоки данных на временные промежутки? стастику собирать? или что? pandas - это про статистику, вроде как
ну вот как пример:
есть евенты каждые 30 секунд
а надо смёржить их, чтобы типа они каждые 5 минут, а данные из евента соотвественно средние взять
это, конечно, можно сделать портяночкой, но так не хочетсяв чистом виде как работа с графиком метрик, только в коде
Илья25.05.2018
12:23:35
12:23:35
мне кажется, это можно сделать руками, и это будет проще, чем использовать пакет time series
Tom25.05.2018
12:24:12
12:24:12
Точно. Но вопрос был про есть чо в Го
Илья25.05.2018
12:25:12
12:25:12
а функции агрегаты в КХ не осилят задачу? :O
Андрей25.05.2018
12:26:38
12:26:38
может и осилят, но там из одной выборки надо несколько разных результатов сделать, а данных немало
поэтому в целях перфоманса в ту сторону не смотрю
Tom25.05.2018
12:28:43
12:28:43
Кстати, да. КХ очень быстрый же. На нем Я Метрика не просто так крутится.
С другой стороны, отличный опенсорс на Го можно запилить)
GoogleАндрей25.05.2018
12:31:42
12:31:42
ну, быстрый то это да, но данных многовато гонять получается, хочу один раз выбрать, а потом с ними играть
Zae25.05.2018
14:51:31
14:51:31
Добрый вечер, делаю небольшой сервер, который читает .csv файлы, парсит их и отдает в жсоне. Проблема в том, что массив при json.Marshal() содержит пустые объекты вместо данных, при этом, если делаю json.Unmarshal() обратно, данные присутствуют
В чем может быть проблема?
Илья25.05.2018
14:56:49
14:56:49
сделайте простой пример на https://play.golang.org/
Zae25.05.2018
14:57:25
14:57:25
Ой, прошу прощения, проблема была том что я в struct не вписал значения для json
https://stackoverflow.com/questions/26327391/json-marshalstruct-returns
Roman25.05.2018
16:47:02
16:47:02
Подскажите какое-нибудь чтиво по архитектуре приложений (не обязательно веб) в реалиях го
Сергей25.05.2018
16:50:42
16:50:42
Подскажите какое-нибудь чтиво по архитектуре приложений (не обязательно веб) в реалиях го
Реалии го - лапша из микросервисовRoman25.05.2018
16:51:44
16:51:44
Реалии го - лапша из микросервисов
Спорить не буду, но и микросервис хочется "красиво структурировать".
Aleksandr25.05.2018
16:52:52
16:52:52
тогда спрашивай о структуре проектов, а не об архитектуре
Roman25.05.2018
16:53:41
16:53:41
в общем я о mvc, mvvm и прочем
Aleksandr25.05.2018
16:54:57
16:54:57
ну так юзай mvc, mvvm - это в общем-то независящие от языка паттерны
Tom25.05.2018
17:19:43
17:19:43
@xmpln Design Data-Intensive Data Applications + Clean Architecture
Roman25.05.2018
17:19:57
17:19:57
Tom25.05.2018
17:20:36
17:20:36
Не в контексте Go, но лично я лучше не встречал из современного.
Сергей25.05.2018
17:27:48
17:27:48
Спорить не буду, но и микросервис хочется "красиво структурировать".
Красиво структурировать - это микросервисы из монолита вырастают естественным образом, либо у тебя за руками 10+ лет опыта и ты знаешь что делаешьАлександр25.05.2018
17:36:25
17:36:25
Influxdb по udp НЕ переваривает int, запись уходит в мусорку сразу. По http api работает.
нужно использовать только float64 значения
Открыть в Telegram