#app/models/data_warehouse.rb
class DataWarehouse < ActiveRecord::Base
establish_connection "redshift_staging"
#or, if you want to have a db per environment
#establish_connection "redshift_#{Rails.env}"
end
Обратите внимание, что мы подключаемся к 5439, а не к 5432 по умолчанию, поэтому я указываю порт. Кроме того, я указываю схему, бета-версию, которую мы используем для наших нестабильных агрегатов. У вас может быть либо другая база данных для каждой среды, как указано выше, либо использовать различные схемы и включать их в путь поиска для ActiveRecord
#config/database.yml
redshift_staging:
adapter: postgresql
encoding: utf8
database: db03
port: 5439
pool: 5
schema_search_path: 'beta'
username: admin
password: supersecretpassword
host: db03.myremotehost.us #your remote host here, might be an aws url from Redshift admin console
###ВАРИАНТ 2, прямое подключение к PG
class DataWarehouse < ActiveRecord::Base
attr_accessor :conn
def initialize
@conn = PG.connect(
database: 'db03',
port: 5439,
pool: 5,
schema_search_path: 'beta',
username: 'admin',
password: 'supersecretpassword',
host: 'db03.myremotehost.us'
)
end
end
[DEV] main:0> redshift = DataWarehouse
E, [2014-07-17T11:09:17.758957 #44535] ERROR -- : PG::InsufficientPrivilege: ERROR: permission denied to set parameter "client_min_messages" to "notice" : SET client_min_messages TO 'notice'
(pry) output error: #<ActiveRecord::StatementInvalid: PG::InsufficientPrivilege: ERROR: permission denied to set parameter "client_min_messages" to "notice" : SET client_min_messages TO 'notice'>
ОБНОВЛЕНИЕ:
В итоге я остановился на варианте 1, но пока использую этот адаптер по нескольким причинам:
https://github.com/fiksu/activerecord-redshift-adapter
Причина 1: адаптер ActiveRecord postgresql устанавливает client_min_messages. Причина 2: адаптер также пытается установить часовой пояс, что не позволяет redshift (http://docs.aws.amazon.com/redshift/latest/dg/c_redshift-and-postgres-sql.html) Причина 3. Даже если вы измените код в ActiveRecord для первых двух ошибок, вы сталкиваетесь с дополнительными ошибками, которые жалуются, что Redshift использует Postgresql 8.0, в этот момент я перешел к адаптеру, вернусь и обновлю, если позже найду что-то лучше.
Я переименовал свою таблицу в base_aggregate_redshift_tests (обратите внимание на множественное число), чтобы ActiveRecord можно было легко подключить, если вы не можете изменить имена таблиц в redshift, используйте метод set_table, который я прокомментировал ниже.
#Gemfile:
gem 'activerecord4-redshift-adapter', github: 'aamine/activerecord4-redshift-adapter'
Опция 1
#config/database.yml
redshift_staging:
adapter: redshift
encoding: utf8
database: db03
port: 5439
pool: 5
username: admin
password: supersecretpassword
host: db03.myremotehost.us
timeout: 5000
#app/models/base_aggregates_redshift_test.rb
#Model named to match my tables in Redshift, if you want you can set_table like I have commented out below
class BaseAggregatesRedshiftTest < ActiveRecord::Base
establish_connection "redshift_staging"
self.table_name = "beta.base_aggregates_v2"
end
в консоли, используя self.table_name — обратите внимание, что он запрашивает правильную таблицу, поэтому вы можете называть свои модели как хотите
[DEV] main:0> redshift = BaseAggregatesRedshiftTest.first
D, [2014-07-17T15:31:58.678103 #43776] DEBUG -- : BaseAggregatesRedshiftTest Load (45.6ms) SELECT "beta"."base_aggregates_v2".* FROM "beta"."base_aggregates_v2" LIMIT 1
Вариант 2
#app/models/base_aggregates_redshift_test.rb
class BaseAggregatesRedshiftTest < ActiveRecord::Base
set_table "beta.base_aggregates_v2"
ActiveRecord::Base.establish_connection(
adapter: 'redshift',
encoding: 'utf8',
database: 'staging',
port: '5439',
pool: '5',
username: 'admin',
password: 'supersecretpassword',
search_schema: 'beta',
host: 'db03.myremotehost.us',
timeout: '5000'
)
end
#in console, abbreviated example of first record, now it's using the new name for my redshift table, just assuming I've got the record at base_aggregates_redshift_tests because I didn't set the table_name
[DEV] main:0> redshift = BaseAggregatesRedshiftTest.first
D, [2014-07-17T15:09:39.388918 #11537] DEBUG -- : BaseAggregatesRedshiftTest Load (45.3ms) SELECT "base_aggregates_redshift_tests".* FROM "base_aggregates_redshift_tests" LIMIT 1
#<BaseAggregatesRedshiftTest:0x007fd8c4a12580> {
:truncated_month => Thu, 31 Jan 2013 19:00:00 EST -05:00,
:dma => "Cityville",
:group_id => 9712338,
:dma_id => 9999
}
Удачи @johncorser!
person
harrisjb
schedule
17.07.2014
