Class: ActiveRecord::Base

Inherits:
Object
  • Object
show all
Defined in:
lib/active_record/connection_adapters/amazon_timestream_adapter.rb

Class Method Summary collapse

Class Method Details

.amazon_timestream_connection(config) ⇒ Object

Raises:

  • (ArgumentError)


13
14
15
16
17
18
19
20
21
22
# File 'lib/active_record/connection_adapters/amazon_timestream_adapter.rb', line 13

def self.amazon_timestream_connection(config)
  config = config.symbolize_keys

  raise ArgumentError, 'No database specified. Missing argument: database.' unless config.key?(:database)

  credentials = Aws::Credentials.new config[:username], config[:password] if config[:username] && config[:password]
  connection = Aws::TimestreamQuery::Client.new credentials: credentials, endpoint: 'https://query-cell2.timestream.us-east-1.amazonaws.com'

  ConnectionAdapters::AmazonTimestreamAdapter.new connection, logger, config[:database]
end