Как вставить текущее время при копировании данных из одного измерения в другое?

Question

Как вставить текущее время при копировании данных из одного измерения в другое.Он правильно копирует все данные вместе с отметкой времени измерения, из которого копируется.

ВЫБРАТЬ МИНУТУ (столбец) в качестве значения INTO db2.retention_policy2.measurement2 FROM db1.retention_policy1.measurement1 GROUP BY column1, column2

Я хочу, чтобы столбец времени в новом измерении (измерение2) имел текущее время, а не время из db1.retention_policy1.measurement1.Это возможно?Спасибо.

Существует один возможный способ преобразования запроса в список:

list_current_data = list(current_data.get_points())

и последующее обновление времени следующим образом:

for item in list_current_data:
    item['time'] = datetime.datetime.utcnow().strftime("%Y-%m-%dT%H:%M:%S.%f")[:-4]+"Z"

Наконец, вставкаданные из обновленного списка в измерение.Кто-нибудь знает, как вставить данные из списка в измерение?

Answer 1

Запись данных из списка в измерение может быть выполнена следующим образом:

current_data = client.query("SELECT statement")
list_current_data = list(current_data.get_points())

for data_point in current_data.get_points():
    data_to_write = [{'measurement': 'measurement_name',
                    'fields': {'value1': data_point['value1'],
                               'value2': data_point['value2']}
                    }]
    client.write_points(data_to_write)

Это добавит новые данные к измерению каждый раз, когда выполняется скрипт.