У меня есть набор данных, в котором необходимо увеличить временную метку на наносекунду, чтобы моя точка не рассматривалась как дубликат. (Получил совет от документации )
Как лучше всего проверить, существует ли в базе данных точка с определенным набором тегов и отметкой времени?
На данный момент я делаю это так:
def duplicate_point(influxdb_client, influxdb_point):
q = "SELECT * FROM random_measurement WHERE time={} AND mac='{}'".format(
influxdb_point['time'],
influxdb_point['tags']['mac']
)
result = influxdb_client.query(q)
return bool(result)
Если результат не пустой, то данная точка является дубликатом. Когда дубликат найден, наносекунда добавляется к метке времени. Я делаю эту проверку каждый раз, когда необходимо записать точку в базу данных, но это сильно влияет на пропускную способность. Существует ли лучший способ решения этой проблемы?