Sha256: e01463700e2f413b24b4fd41a69417b3789f44ffda48c31f2f933ecf155f83ad
Contents?: true
Size: 1.29 KB
Versions: 21
Compression:
Stored size: 1.29 KB
Contents
module Blazer
module Adapters
class InfluxdbAdapter < BaseAdapter
def run_statement(statement, comment)
columns = []
rows = []
error = nil
begin
result = client.query(statement, denormalize: false).first
if result
columns = result["columns"]
rows = result["values"]
# parse time columns
# current approach isn't ideal, but result doesn't include types
# another approach would be to check the format
time_index = columns.index("time")
if time_index
rows.each do |row|
row[time_index] = Time.parse(row[time_index]) if row[time_index]
end
end
end
rescue => e
error = e.message
end
[columns, rows, error]
end
def tables
client.list_series
end
def preview_statement
"SELECT * FROM {table} LIMIT 10"
end
# https://docs.influxdata.com/influxdb/v1.8/query_language/spec/#strings
def quoting
:backslash_escape
end
def parameter_binding
# not supported
end
protected
def client
@client ||= InfluxDB::Client.new(url: settings["url"])
end
end
end
end
Version data entries
21 entries across 21 versions & 3 rubygems