Class: Blazer::Adapters::InfluxdbAdapter
Instance Attribute Summary
Attributes inherited from BaseAdapter
#data_source
Instance Method Summary
collapse
Methods inherited from BaseAdapter
#cachable?, #cancel, #cost, #explain, #initialize, #reconnect, #schema
Instance Method Details
#preview_statement ⇒ Object
34
35
36
|
# File 'lib/blazer/adapters/influxdb_adapter.rb', line 34
def preview_statement
"SELECT * FROM {table} LIMIT 10"
end
|
#run_statement(statement, comment) ⇒ Object
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
# File 'lib/blazer/adapters/influxdb_adapter.rb', line 4
def run_statement(statement, )
columns = []
rows = []
error = nil
begin
result = client.query(statement, denormalize: false).first
columns = result["columns"]
rows = result["values"]
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
rescue => e
error = e.message
end
[columns, rows, error]
end
|
#tables ⇒ Object
30
31
32
|
# File 'lib/blazer/adapters/influxdb_adapter.rb', line 30
def tables
client.list_series
end
|