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
|