Active Support Instrumentation

ActiveSupport::Notifications.subscribe "process_action.action_controller" do |event|
  event.name        # => "process_action.action_controller" 
  event.duration    # => 10 (밀리초 단위)
  event.allocations # => 1826
  event.payload     # => {:extra=>information}

  Rails.logger.info "#{event} 수신완료!"
end

ActiveSupport::Notifications.subscribe "process_action.action_controller" do |name, started, finished, unique_id, payload|
  # 사용자 정의 코드
  Rails.logger.info "#{name} 수신됨! (시작: #{started}, 종료: #{finished})" # process_action.action_controller 수신됨! (시작: 2019-05-05 13:43:57 -0800, 종료: 2019-05-05 13:43:58 -0800)
end

ActiveSupport::Notifications.monotonic_subscribe "process_action.action_controller" do |name, started, finished, unique_id, payload|
  # 사용자 정의 코드
  duration = finished - started # 1560979.429234 - 1560978.425334
  Rails.logger.info "#{name} 수신됨! (duration: #{duration})" # process_action.action_controller 수신됨! (duration: 1.0039)
end

ActiveSupport::Notifications.subscribe(/action_controller/) do |event|
  # 모든 ActionController 이벤트 검사
end

{
  controller: "PostsController",
  action: "new", 
  params: { "action" => "new", "controller" => "posts" },
  headers: #<ActionDispatch::Http::Headers:0x0055a67a519b88>,
  format: :html,
  method: "GET",
  path: "/posts/new"
}

{
  controller: "PostsController",
  action: "index", 
  params: {"action" => "index", "controller" => "posts"},
  headers: #<ActionDispatch::Http::Headers:0x0055a67a519b88>,
  format: :html,
  method: "GET",
  path: "/posts",
  request: #<ActionDispatch::Request:0x00007ff1cb9bd7b8>,
  response: #<ActionDispatch::Response:0x00007f8521841ec8>,
  status: 200,
  view_runtime: 46.848, # 뷰 렌더링 시간(밀리초)
  db_runtime: 0.157 # 데이터베이스 쿼리 시간(밀리초)
}

{
  status: 302,
  location: "http://localhost:3000/posts/new",
  request: <ActionDispatch::Request:0x00007ff1cb9bd7b8>
} 

{
  filter: ":halting_filter"
}

{
  filename: "subscribers.csv",
  type: "text/csv",
  disposition: "attachment" # 첨부파일
}

{
  key: 'posts/1-dashboard-view'
}

{
  key: 'posts/1-dashboard-view'
}

{
  key: 'posts/1-dashboard-view'
}

{
  key: 'posts/1-dashboard-view'
}

{
  identifier: "/Users/adam/projects/notifications/app/views/posts/index.html.erb",
  layout: "layouts/application", 
  locals: { foo: "bar" }
}

{
  identifier: "/Users/adam/projects/notifications/app/views/posts/_form.html.erb",
  locals: { foo: "bar" }
}

{
  identifier: "/Users/adam/projects/notifications/app/views/posts/_post.html.erb",
  count: 3,
  cache_hits: 0
}

{
  identifier: "/Users/adam/projects/notifications/app/views/layouts/application.html.erb"
}

{
  sql: "SELECT \"posts\".* FROM \"posts\" ", # SQL 쿼리문
  name: "Post Load", # 수행된 작업 이름
  connection: <ActiveRecord::ConnectionAdapters::SQLite3Adapter:0x00007f9f7a838850>, # 데이터베이스 연결 어댑터 
  transaction: <ActiveRecord::ConnectionAdapters::RealTransaction:0x0000000121b5d3e0> # 트랜잭션 정보
  binds: [<ActiveModel::Attribute::WithCastValue:0x00007fe19d15dc00>], # SQL 바인딩 파라미터
  type_casted_binds: [11], # 타입 캐스팅된 바인딩 값들
  statement_name: nil, # 준비된 구문의 이름
  row_count: 5, # 조회된 행 수
  affected_rows: 0 # 영향을 받은 행 수
}

{
  record_count: 1,
  class_name: "User"
}

ActiveRecord::Base.transaction do
  # 블록 내부에 있지만 아직 아무 이벤트도 발생하지 않았습니다.

  # 다음 라인에서 Active Record가 transaction을 시작합니다.
  User.count # 여기서 이벤트가 발생합니다.
end

ActiveRecord::Base.transaction do |t1|
  User.count # t1에 대한 이벤트를 발생시킴
  ActiveRecord::Base.transaction do |t2|
    # 다음 라인은 t2에 대한 이벤트를 발생시키지 않음
    # 이 예제에서 실제 데이터베이스 transaction은 t1 뿐이기 때문
    User.first.touch
  end
end

ActiveRecord::Base.transaction do |t1|
  User.count # t1에 대한 이벤트를 발생시킵니다.
  ActiveRecord::Base.transaction(requires_new: true) do |t2|
    User.first.touch # t2에 대한 이벤트를 발생시킵니다.
  end
end

{
  mailer: "Notification",
  message_id: "4f5b5491f1774_181b23fc3d4434d38138e5@mba.local.mail",
  subject: "Rails Guides",
  to: ["users@rails.com", "dhh@rails.com"],
  from: ["me@rails.com"],
  date: Sat, 10 Mar 2012 14:18:09 +0100,
  mail: "...", # 간단히 하기 위해 생략
  perform_deliveries: true 
}

{
  mailer: "Notification",
  action: "welcome_email", 
  args: []
}

{
  key: "name-of-complicated-computation",
  store: "ActiveSupport::Cache::MemCacheStore"
}

{
  key: "name-of-complicated-computation",
  store: "ActiveSupport::Cache::MemCacheStore"  
}

{
  key: "name-of-complicated-computation", 
  store: "ActiveSupport::Cache::MemCacheStore"
}

{
  key: "bottles-of-beer", 
  store: "ActiveSupport::Cache::RedisCacheStore",
  amount: 99
}

{
  key: "bottles-of-beer",
  store: "ActiveSupport::Cache::RedisCacheStore",
  amount: 1
}

{
  key: "복잡한-계산의-이름",
  store: "ActiveSupport::Cache::MemCacheStore"
}

{
  key: "posts/*", 
  store: "ActiveSupport::Cache::RedisCacheStore"
}

{
  store: "ActiveSupport::Cache::MemoryStore",
  size: 9001
}

{
  store: "ActiveSupport::Cache::MemoryStore",
  key: 5000,
  from: 9001
}

{
  key: "name-of-complicated-computation", 
  store: "ActiveSupport::Cache::MemCacheStore"
}

{
  serializer: :json_allow_marshal,
  fallback: :marshal,
  serialized: "\x04\b{\x06I\"\nHello\x06:\x06ETI\"\nWorld\x06;\x00T", 
  deserialized: { "Hello" => "World" },
}

{
  mailbox: #<RepliesMailbox:0x00007f9f7a8388>,
  inbound_email: {
    id: 1,
    message_id: "0CB459E0-0336-41DA-BC88-E6E28C697DDB@37signals.com", 
    status: "processing"
  }
}

ActiveSupport::Notifications.instrument "my.custom.event", this: :data do
  # 여기에 사용자 정의 작업을 작성하세요
end

ActiveSupport::Notifications.subscribe "my.custom.event" do |name, started, finished, unique_id, data|
  puts data.inspect # {:this=>:data}
end

ActiveSupport::Notifications.instrument "my.custom.event", this: :data

ActiveSupport::Notifications.subscribe "my.custom.event" do |name, started, finished, unique_id, data|
  puts data.inspect # {:this=>:data}
end