создание генератора данных / утилизатора для притока

Question

Я хочу создать своего рода генератор данных для лабораторной среды.

Я подумал о создании какого-то скрипта, который получит имя метрики, разделенное запятыми, и имя метрики, разделенной запятыми, и получит старые данные из притока-db, поменяет его временную метку на текущее время и сохранит его для притока. -db.

Я не уверен, что будет лучшим и простым способом сделать это, скрипт на питоне? конденсатор udf? есть идеи?

Я новичок в тиковой среде, поэтому могу действительно использовать некоторые идеи:)

спасибо, Дэвид,

Answer 1

нашли идеальный способ, быстро и просто, используя kapacitor, даже не нужно создавать udf ...

создайте этот тиковый скрипт и определите его как задачу kapacitor:

var data = batch
    |query(''' SELECT * FROM "My_DB"."My_RP"."My_Measurement" ''')
        .period(1d)
        .every(30s)
        .offset(10d)
data
    |shift(10d)
    |influxDBOut()
        .create()
        .database('My_DB')
        .measurement('My_Measurement')

работает как магия!