Module: InfluxDB::Query::Core
- Included in:
- Client
- Defined in:
- lib/influxdb/query/core.rb
Overview
rubocop:disable Metrics/AbcSize
Instance Method Summary collapse
- #builder ⇒ Object
- #ping ⇒ Object
-
#query(query, params: nil, denormalize: config.denormalize, chunk_size: config.chunk_size, **opts) ⇒ Object
rubocop:disable Metrics/MethodLength.
- #version ⇒ Object
- #write(data, precision, retention_policy = nil, database = nil) ⇒ Object
-
#write_point(series, data, precision = nil, retention_policy = nil, database = nil) ⇒ Object
Example: write_point(‘cpu’, tags: ‘us’, values: 60).
-
#write_points(data, precision = nil, retention_policy = nil, database = nil) ⇒ Object
Example: write_points([ { series: ‘cpu’, tags: { host: ‘server_nl’, regios: ‘us’ }, values: 5, external: 6, timestamp: 1422568543702900257 }, { series: ‘gpu’, values: 0.9999, } ]).
Instance Method Details
#builder ⇒ Object
7 8 9 |
# File 'lib/influxdb/query/core.rb', line 7 def builder @builder ||= Builder.new end |
#ping ⇒ Object
11 12 13 14 |
# File 'lib/influxdb/query/core.rb', line 11 def ping url = URI::Generic.build(path: File.join(config.prefix, '/ping')).to_s get url end |
#query(query, params: nil, denormalize: config.denormalize, chunk_size: config.chunk_size, **opts) ⇒ Object
rubocop:disable Metrics/MethodLength
21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 |
# File 'lib/influxdb/query/core.rb', line 21 def query( query, params: nil, denormalize: config.denormalize, chunk_size: config.chunk_size, **opts ) query = builder.build(query, params) url = full_url("/query".freeze, query_params(query, opts)) series = fetch_series(get(url, parse: true, json_streaming: !chunk_size.nil?)) if block_given? series.each do |s| values = denormalize ? denormalize_series(s) : raw_values(s) yield s['name'.freeze], s['tags'.freeze], values end else denormalize ? denormalized_series_list(series) : series end end |
#version ⇒ Object
16 17 18 |
# File 'lib/influxdb/query/core.rb', line 16 def version ping.header['x-influxdb-version'] end |
#write(data, precision, retention_policy = nil, database = nil) ⇒ Object
73 74 75 76 77 78 79 80 81 82 |
# File 'lib/influxdb/query/core.rb', line 73 def write(data, precision, retention_policy = nil, database = nil) params = { db: database || config.database, precision: precision || config.time_precision, } params[:rp] = retention_policy if retention_policy url = full_url("/write", params) post(url, data) end |
#write_point(series, data, precision = nil, retention_policy = nil, database = nil) ⇒ Object
Example: write_point(‘cpu’, tags: ‘us’, values: 60)
69 70 71 |
# File 'lib/influxdb/query/core.rb', line 69 def write_point(series, data, precision = nil, retention_policy = nil, database = nil) write_points(data.merge(series: series), precision, retention_policy, database) end |
#write_points(data, precision = nil, retention_policy = nil, database = nil) ⇒ Object
Example: write_points([
{
series: 'cpu',
tags: { host: 'server_nl', regios: 'us' },
values: {internal: 5, external: 6},
timestamp: 1422568543702900257
},
{
series: 'gpu',
values: {value: 0.9999},
}
])
57 58 59 60 61 62 63 64 65 |
# File 'lib/influxdb/query/core.rb', line 57 def write_points(data, precision = nil, retention_policy = nil, database = nil) data = data.is_a?(Array) ? data : [data] payload = generate_payload(data) writer.write(payload, precision, retention_policy, database) rescue StandardError => e raise e unless config.discard_write_errors log :error, "Cannot write data: #{e.inspect}" end |