Active Supportが提供するInstrumentation APIを使ってフックを開発すると、他の開発者がそこにフックできるようになります。Railsフレームワーク内部にはさまざまなフックが用意されています。このAPIをアプリケーションで実装すると、アプリケーション(またはRubyコード片)内部でイベントが発生したときに通知を受け取れるよう他の開発者が設定できます。
たとえばActive Recordには、データベースへのSQLクエリが発行されるたびに呼び出されるフックが用意されています。このフックをサブスクライブ(購読)すると、特定のアクションでのクエリ実行数を追跡できます。他に、コントローラのアクション実行中に呼び出されるフックもあります。このフックは、たとえば特定のアクション実行に要した時間のトラッキングに利用できます。
アプリケーション内に独自のイベントを作成し、後で自分でサブスクライブして測定することも可能です。
イベントは簡単にサブスクライブできます。ActiveSupport::Notifications.subscribe
をブロック付きで記述すれば、すべての通知をリッスンできます。
ブロックには以下の引数を渡せます。
- イベント名
- イベントの開始時刻
- イベントの終了時刻
- イベントを発火させたinstrumenterのユニークID
- イベントのペイロード
ActiveSupport::Notifications.subscribe "process_action.action_controller" do |name, started, finished, unique_id, data|
# 自分のコードをここに書く
Rails.logger.INFO:"#{name} Received! (started: #{started}, finished: #{finished})" # process_action.action_controller Received (started: 2019-05-05 13:43:57 -0800, finished: 2019-05-05 13:43:58 -0800)
end
経過時間を正確に算出するうえでstarted
とfinished
の精度が気になる場合は、ActiveSupport::Notifications.monotonic_subscribe
をお使いください。ここに渡すブロックで使える引数は上述と同じですが、started
とfinished
の値に通常のクロック時刻(wall-clock time)ではなく単調増加する精密な時刻が使われるようになります。
ActiveSupport::Notifications.monotonic_subscribe "process_action.action_controller" do |name, started, finished, unique_id, data|
# 自分のコードをここに書く
Rails.logger.INFO:"#{name} Received! (started: #{started}, finished: #{finished})" # process_action.action_controller Received (started: 1560978.425334, finished: 1560979.429234)
end
ブロックの引数を毎回定義しなくても済むよう、次のようなブロック付きのActiveSupport::Notifications::Event
を簡単に定義できます。
ActiveSupport::Notifications.subscribe "process_action.action_controller" do |*args|
event = ActiveSupport::Notifications::Event.new(*args)
event.name # => "process_action.action_controller"
event.duration # => 10 (in milliseconds)
event.payload # => {:extra=>information}
Rails.logger.INFO:"#{event} Received!"
end
また、以下のように引数を1個だけ受け取るブロックを渡すと、イベントオブジェクトを受け取れます。
ActiveSupport::Notifications.subscribe "process_action.action_controller" do |event|
event.name # => "process_action.action_controller"
event.duration # => 10 (in milliseconds)
event.payload # => {:extra=>information}
Rails.logger.INFO:"#{event} Received!"
end
正規表現に一致するイベントだけをサブスクライブすることも可能です。これはさまざまなイベントを一括でサブスクライブしたい場合に便利です。以下は、ActionController
のイベントをすべて登録する場合の例です。
ActiveSupport::Notifications.subscribe(/action_controller/) do |*args|
# ActionControllerの全イベントをチェック
end
Ruby on Railsでは、フレームワーク内の主なイベント向けのフックが多数提供されています。イベントとペイロードについて詳しくは以下をご覧ください。
キー |
値 |
:controller |
コントローラ名 |
:action |
アクション |
:request |
ActionDispatch::Request オブジェクト |
:params |
リクエストパラメータのハッシュ(フィルタされたパラメータは含まない) |
:headers |
リクエスト ヘッダー |
:format |
html/js/json/xml など |
:method |
HTTP リクエストメソッド(verb) |
:path |
リクエスト パス |
{
controller: "PostsController",
action: "new",
params: { "action" => "new", "controller" => "posts" },
headers: #<ActionDispatch::Http::Headers:0x0055a67a519b88>,
format: :html,
method: "GET",
path: "/posts/new"
}
キー |
値 |
:controller |
コントローラ名 |
:action |
アクション |
:params |
リクエストパラメータのハッシュ(フィルタされたパラメータは含まない) |
:headers |
リクエスト ヘッダー |
:format |
html/js/json/xml など |
:method |
HTTP リクエストメソッド(verb) |
:path |
リクエスト パス |
:request |
ActionDispatch::Request オブジェクト |
:response |
ActionDispatch::Response オブジェクト |
:status |
HTTP ステータスコード |
:view_runtime |
ビューでかかった合計時間(ms) |
:db_runtime |
データベースへのクエリ実行にかかった時間(ms) |
{
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
}
呼び出し側でキーが追加される可能性があります。
ActionController
はペイロードに特定の情報を追加しません。オプションは、すべてペイロード経由で渡されます。
{
status: 302,
location: "http://localhost:3000/posts/new",
request: <ActionDispatch::Request:0x00007ff1cb9bd7b8>
}
キー |
値 |
:filter |
アクションを停止させたフィルタ |
{
filter: ":halting_filter"
}
キー |
値 |
:keys |
許可されていないキー |
:context |
以下のキーを持つハッシュ: :controller 、:action 、:params 、:request
|
{
key: 'posts/1-dashboard-view'
}
{
key: 'posts/1-dashboard-view'
}
{
key: 'posts/1-dashboard-view'
}
{
key: 'posts/1-dashboard-view'
}
キー |
値 |
:identifier |
テンプレートへの完全なパス |
:layout |
該当のレイアウト |
:locals |
テンプレートに渡されるローカル変数 |
{
identifier: "/Users/adam/projects/notifications/app/views/posts/index.html.erb",
layout: "layouts/application",
locals: { foo: "bar" }
}
キー |
値 |
:identifier |
テンプレートへの完全なパス |
:locals |
テンプレートに渡されるローカル変数 |
{
identifier: "/Users/adam/projects/notifications/app/views/posts/_form.html.erb",
locals: { foo: "bar" }
}
キー |
値 |
:identifier |
テンプレートへのフルパス |
:count |
コレクションのサイズ |
:cache_hits |
キャッシュからフェッチしたパーシャルの個数 |
:cache_hits
は、cached: true
をオンにしてレンダリングしたときだけ含まれます。
{
identifier: "/Users/adam/projects/notifications/app/views/posts/_post.html.erb",
count: 3,
cache_hits: 0
}
キー |
値 |
:identifier |
テンプレートへのフルパス |
{
identifier: "/Users/adam/projects/notifications/app/views/layouts/application.html.erb"
}
キー |
値 |
:sql |
SQL文 |
:name |
操作の名前 |
:connection |
コネクションオブジェクト |
:binds |
バインドするパラメータ |
:type_casted_binds |
型キャストされたバインドパラメータ |
:statement_name |
SQL文の名前 |
:cached |
キャッシュされたクエリが使われるとtrue が追加される |
アダプタが独自のデータを追加する可能性もあります。
{
sql: "SELECT \"posts\".* FROM \"posts\" ",
name: "Post Load",
connection: <ActiveRecord::ConnectionAdapters::SQLite3Adapter:0x00007f9f7a838850>,
binds: [<ActiveModel::Attribute::WithCastValue:0x00007fe19d15dc00>],
type_casted_binds: [11],
statement_name: nil
}
このイベントはconfig.active_record.action_on_strict_loading_violation
が:log
に設定されている場合にのみ発火します。
キー |
値 |
:owner |
strict_loading が有効化されたモデル |
:reflection |
読み込もうとしている関連付けのリフレクション |
キー |
値 |
:record_count |
レコードのインスタンス数 |
:class_name |
レコードのクラス |
{
record_count: 1,
class_name: "User"
}
キー |
値 |
:mailer |
メーラークラス名 |
:message_id |
Mail gemが生成したメッセージID |
:subject |
メールの件名 |
:to |
メールの宛先(複数可) |
:from |
メールの差出人 |
:bcc |
メールのBCCアドレス(複数可) |
:cc |
メールのCCアドレス(複数可) |
:date |
メールの日付 |
:mail |
メールのエンコード形式 |
:perform_deliveries |
このメッセージが配信されたかどうか |
{
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 |
メーラーのクラス名 |
:action |
アクション |
:args |
引数 |
{
mailer: "Notification",
action: "welcome_email",
args: []
}
キー |
値 |
:key |
ストアで使われるキー |
:store |
ストアクラス名 |
:hit |
ヒットしたかどうか |
:super_operation |
fetch で読み出された場合は:fetch
|
キー |
値 |
:key |
ストアで使われるキー |
:store |
ストアクラス名 |
:hits |
ヒットしたかどうか |
:super_operation |
fetch_multi で読み出された場合はfetch_multi を追加 |
このイベントは、fetch
をブロック付きで呼び出した場合にのみ使われます。
キー |
値 |
:key |
ストアで使われるキー |
:store |
ストアクラス名 |
#fetch
に渡されたオプションは、ストアへの書き込み時にペイロードとマージされます。
{
key: "name-of-complicated-computation",
store: "ActiveSupport::Cache::MemCacheStore"
}
このイベントは、fetch
をブロック付きで呼び出した場合にのみ使われます。
キー |
値 |
:key |
ストアで使われるキー |
:store |
ストアクラス名 |
fetch
に渡されたオプションは、ペイロードとマージされます。
{
key: "name-of-complicated-computation",
store: "ActiveSupport::Cache::MemCacheStore"
}
キー |
値 |
:key |
ストアで使われるキー |
:store |
ストアクラス名 |
キャッシュストアが独自のデータを追加する可能性もあります。
{
key: "name-of-complicated-computation",
store: "ActiveSupport::Cache::MemCacheStore"
}
キー |
値 |
:key |
ストアで使われるキーと値 |
:store |
ストアクラス名 |
このイベントは、MemCacheStore
またはRedisCacheStore
を使った場合にのみ発火します。
キー |
値 |
:key |
ストアで使われるキー |
:store |
ストアクラス名 |
:amount |
インクリメントする量 |
{
key: "bottles-of-beer",
store: "ActiveSupport::Cache::RedisCacheStore",
amount: 99
}
このイベントは、MemCacheStore
またはRedisCacheStore
を使った場合にのみ発火します。
キー |
値 |
:key |
ストアで使われるキー |
:store |
ストアクラス名 |
:amount |
デクリメントする量 |
{
key: "bottles-of-beer",
store: "ActiveSupport::Cache::RedisCacheStore",
amount: 1
}
キー |
値 |
:key |
ストアで使われるキー |
:store |
ストアクラス名 |
{
key: "name-of-complicated-computation",
store: "ActiveSupport::Cache::MemCacheStore"
}
キー |
値 |
:key |
ストアで使われるキー |
:store |
ストアクラス名 |
このイベントは、RedisCacheStore
、 FileStore
、またはMemoryStore
を使った場合にのみ発火します。
キー |
値 |
:key |
使われるキーのパターン |
:store |
ストアクラス名 |
{
key: "posts/*",
store: "ActiveSupport::Cache::RedisCacheStore"
}
このイベントは、MemoryStore
を使った場合にのみ発火します。
キー |
値 |
:store |
ストアクラス名 |
:size |
クリーンアップ前のキャッシュにあるエントリ数 |
{
store: "ActiveSupport::Cache::MemoryStore",
size: 9001
}
このイベントは、MemoryStore
を使った場合にのみ発火します。
キー |
値 |
:store |
ストアクラス名 |
:key |
キャッシュのターゲットサイズ(バイト単位) |
:from |
prune(刈込)前のキャッシュサイズ(バイト単位) |
{
store: "ActiveSupport::Cache::MemoryStore",
key: 5000,
from: 9001
}
キー |
値 |
:key |
ストアで使われるキー |
:store |
ストアクラス名 |
{
key: "name-of-complicated-computation",
store: "ActiveSupport::Cache::MemCacheStore"
}
キー |
値 |
:serializer |
プライマリ(意図した)シリアライザ |
:fallback |
フォールバック(実際の)シリアライザ |
:serialized |
シリアライズされた文字列 |
:deserialized |
デシリアライズされた値 |
{
serializer: :json_allow_marshal,
fallback: :marshal,
serialized: "\x04\b{\x06I\"\nHello\x06:\x06ETI\"\nWorld\x06;\x00T",
deserialized: { "Hello" => "World" },
}
キー |
値 |
:adapter |
ジョブを処理するQueueAdapterオブジェクト |
:job |
Jobオブジェクト |
キー |
値 |
:adapter |
ジョブを処理するQueueAdapterオブジェクト |
:job |
Jobオブジェクト |
キー |
値 |
:job |
Jobオブジェクト |
:adapter |
ジョブを処理するQueueAdapterオブジェクト |
:error |
リトライが原因で発生したエラー |
:wait |
リトライの遅延 |
キー |
値 |
:adapter |
ジョブを処理するQueueAdapterオブジェクト |
:jobs |
Jobオブジェクトの配列 |
キー |
値 |
:adapter |
ジョブを処理するQueueAdapterオブジェクト |
:job |
Jobオブジェクト |
キー |
値 |
:adapter |
ジョブを処理するQueueAdapterオブジェクト |
:job |
Jobオブジェクト |
:db_runtime |
データベースクエリの総実行時間(ms) |
キー |
値 |
:adapter |
ジョブを処理するQueueAdapterオブジェクト |
:job |
Jobオブジェクト |
:error |
リトライが原因で発生したエラー |
キー |
値 |
:adapter |
ジョブを処理するQueueAdapterオブジェクト |
:job |
Jobオブジェクト |
:error |
リトライが原因で発生したエラー |
キー |
値 |
:channel_class |
チャネルのクラス名 |
:action |
アクション |
:data |
日付(ハッシュ) |
キー |
値 |
:channel_class |
チャネルのクラス名 |
:action |
アクション |
:via |
経由先 |
キー |
値 |
:channel_class |
チャネルのクラス名 |
キー |
値 |
:channel_class |
チャネルのクラス名 |
キー |
値 |
:broadcasting |
名前付きブロードキャスト |
:message |
メッセージ(ハッシュ) |
:coder |
コーダー |
キー |
値 |
:analyzer |
アナライザ名(ffprobeなど) |
キー |
値 |
:key |
セキュアトークン |
:service |
サービス名 |
:checksum |
完全性を担保するチェックサム |
キー |
値 |
:key |
セキュアトークン |
:service |
サービス名 |
キー |
値 |
:key |
セキュアトークン |
:service |
サービス名 |
:range |
読み取りを試行するバイト範囲 |
キー |
値 |
:key |
セキュアトークン |
:service |
サービス名 |
キー |
値 |
:key |
セキュアトークン |
:service |
サービス名 |
キー |
値 |
:prefix |
キーのプレフィックス |
:service |
サービス名 |
キー |
値 |
:key |
セキュアトークン |
:service |
サービス名 |
:exist |
ファイルまたはblobが存在するかどうか |
キー |
値 |
:key |
セキュアトークン |
:service |
サービス名 |
:url |
生成されたURL |
このイベントはGoogle Cloud Storageサービスを使っている場合にのみ発火します。
キー |
値 |
:key |
セキュアトークン |
:service |
サービス名 |
:content_type |
HTTP Content-Type フィールド |
:disposition |
HTTP Content-Disposition フィールド |
Key |
Value |
:mailbox |
ActionMailbox::Base から継承したMailboxクラスのインスタンス |
:inbound_email |
処理中の受信メールに関するデータのハッシュ |
{
mailbox: #<RepliesMailbox:0x00007f9f7a8388>,
inbound_email: {
id: 1,
message_id: "0CB459E0-0336-41DA-BC88-E6E28C697DDB@37signals.com",
status: "processing"
}
}
キー |
値 |
:initializer |
config/initializers で読み込まれたイニシャライザへのパス |
キー |
値 |
:message |
非推奨機能の警告メッセージ |
:callstack |
非推奨警告の発生元 |
:gem_name |
非推奨警告で報告されたgem名 |
:deprecation_horizon |
非推奨の振る舞いが削除されるバージョン |
instrumentationの途中で例外が発生すると、ペイロードにその情報が含まれます。
キー |
値 |
:exception |
2個の要素(例外クラス名とメッセージ)を持つ配列 |
:exception_object |
例外オブジェクト |
独自のイベントを自由に追加できます。Active Supportは、面倒な作業を代行してくれます。イベント追加は、name
、payload
、ブロックを指定してActiveSupport::Notifications.instrument
を呼び出すだけで完了します。
通知は、ブロックが戻ってから送信されます。Active Supportでは、開始時刻、終了時刻、InstrumenterのユニークIDが生成されます。instrument
呼び出しに渡されるすべてのデータがペイロードに含まれます。
以下に例を示します。
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
以下のように、ブロックを渡さずにinstrument
を呼び出すことも可能です。これにより、instrumentationインフラストラクチャを他のメッセージング用途に活用できます。
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
独自のイベントを作成するときは、Railsの規約に従ってください。形式は「event.library
」を使います。
たとえば、アプリケーションがツイートを送信するのであれば、イベント名はtweet.twitter
となります。
🖋 GitHubで編集を提案する
/
📕 英語で読む
Railsガイドは GitHub の yasslab/railsguides.jp で管理・公開されております。本ガイドを読んで気になる文章や間違ったコードを見かけたら、気軽に Pull Request を出して頂けると嬉しいです。Pull Request の送り方については GitHub の README をご参照ください。
原著における間違いを見つけたら『Rails のドキュメントに貢献する』を参考にしながらぜひ Rails コミュニティに貢献してみてください 🛠💨✨
本ガイドの品質向上に向けて、皆さまのご協力が得られれば嬉しいです。
Railsガイド運営チーム (@RailsGuidesJP)
Railsガイドは下記の協賛企業から継続的な支援を受けています。支援・協賛にご興味あれば協賛プランからお問い合わせいただけると嬉しいです。
- Star
-
-