Adjust のリアルタイムコールバックを Cloud Logging に流す
1. はじめに
Adjust のリアルタイムコールバックを利用すると、 Adjust の計測結果を指定のサーバーに送信する事ができます。
この記事では、 Adjust のデータを Cloud Functions に送信して Cloud Logging へ流すための設計をまとめます。
2. アーキテクチャ
Adjust でリアルタイムコールバックを利用する際、受け口となるサーバーが必要となります。
今回は Cloud Logging へ送る事が目的なので、同じ GCP の Cloud Functions を使います。
3. サーバーを建てる
アーキテクチャで記述した通り、サーバーには Cloud Functions を利用します。
以下のパラメータで Cloud Functions を作成します。
Cloud Functions の設定
項目 | 設定内容 |
---|---|
関数名 | adjust-server |
リージョン | asia-northeast1 |
トリガーのタイプ | HTTP |
認証 | 認証が必要 |
ランタイム | Go 1.13 |
エントリポイント | GetRawData |
Cloud Functions は複数言語のランタイムに対応していますが、今回は Go 1.13 で実行します。
ログの出力は構造を変更しやすいように uber-go/zap を利用します。
package p
import (
"fmt"
"net/http"
"go.uber.org/zap"
)
var zlogger *zap.Logger
func init() {
var err error
zlogger, err = zap.NewProduction()
if err != nil {
fmt.Printf("request parse failed. %v", err)
return
}
}
func GetRawData(_ http.ResponseWriter, r *http.Request) {
if err := r.ParseForm(); err != nil {
fmt.Printf("request parse failed. %v", err)
return
}
fields := make([]zap.Field, 0, len(r.Form)+1)
fields = append(fields, zap.Namespace("body"))
for k, v := range r.Form {
fields = append(fields, zap.String(k, v[0]))
}
zlogger.Info("AdjustLogger", fields...)
}
デプロイが完了したらトリガーURLを叩いてみましょう。
$ curl https://asia-northeast1-${project_id}.cloudfunctions.net/adjust-server
クエリパラメータを追加して叩くと、パラメータ情報もログとして出力されます。
4. Adjust のリアルタイムコールバック設定
Adjust 側で行う設定は以下の公式ドキュメントに書かれています。
データの管理 > ローデータエクスポート > リアルタイムコールバック
抜粋すると、以下の手順で設定できます。
① 該当アプリの下部に表示されている(▲)ボタンを選択します。
② その他の設定 (All Settings)> ローデータエクスポート (Raw Data Export) > リアルタイムコールバック (Real-Time Callbacks)を選択します。
③ グローバルコールバック(GLOBAL CALLBACK)を選択する。
④ コールバックURLを入力します(コールバックURLのテンプレートおよび推奨のプレースホルダーを参照)。
⑤ UPDATEを選択します。
今回は例としてグローバルコールバックを使用します。
コールバックURLは、先ほど作成した Cloud Functions のトリガーURLに必要なクエリパラメータを追加したURLになります。
https://asia-northeast1-${project_id}.cloudfunctions.net/adjust-server?app_id={app_id}&app_name={app_name}
app_id, app_name 以外の情報が欲しい場合は Adjust Placeholders にプレースホルダーのドキュメントがあるので、必要なクエリパラメータを探して設定して下さい。
コールバックURLが設定できたら Adjust のイベントを発火させてみましょう。
正しく疎通できていれば以下のようなログが Cloud Logging に出力され、 jsonPayload.body
の中にプレースホルダーの情報が表示されます。
{
"insertId": "000000-...",
"jsonPayload": {
"msg": "AdjustLogger",
"body": {
"app_id": "foo",
"app_name": "bar"
},
"level": "info",
"caller": "serverless_function_source_code/function.go:33",
},
"resource": {
"type": "cloud_function",
"labels": {
"project_id": "xxx",
"function_name": "adjust-server",
"region": "asia-northeast1"
}
},
...
}
5. IP 制限をかける
これまでの設定で、 Adjust から送られるリアルタイムコールバックの情報を Cloud Logging に流すことができました。
ただ、今のままだと外部から指定のURLに直接アクセスできるので Adjust 以外の情報が混入する可能性があります。
この問題を解決するため、 Cloud Armor で Adjust の IP をホワイトリストに設定します。
Cloud Functions の設定を変更する
まずは作成した Cloud Functions リソースを外部からアクセスできないようにします。
adjust-server の編集を行い、
ランタイム、ビルド、接続の設定
> 接続
> 内部トラフィックと Cloud Load Balancing からのトラフィックを許可する
を設定して更新しましょう。
正しく更新されると、トリガーAPIを叩く際に403エラーが返るようになります。
Cloud Load Balancing を作成する
次に、 Cloud Load Balancing を作成します。
以下の手順でロードバランサーの設定画面に移動します。
Cloud Load Balancing
> ロードバランサを作成
> HTTP(S)負荷分散
インターネット接続の設定は インターネットから自分のVMへ
を選択します。
ロードバランサーの名前は 「adjust-server-lb」 としましょう。
Cloud Load Balancing を作成するためには、バックエンドとフロントエンドの設定をする必要があります。また、今回は Cloud Functions のエンドポイントを設定するため、サーバーレス NEG を設定する必要があります。
バックエンド、フロントエンド、サーバーレス NEG を以下のように設定し、 Cloud Load Balancing を作成します。
バックエンドの設定
項目 | 設定内容 |
---|---|
名前 | adjust-server-backend |
バックエンドタイプ | サーバーレスネットワークエンドポイントグループ |
プロトコル | HTTP |
タイムアウト | 30秒 |
バックエンド | adjust-server-neg (新規作成) |
セキュリティ | なし |
サーバーレス NEG の設定
項目 | 設定内容 |
---|---|
名前 | adjust-server-neg |
リージョン | asia-northeast1 |
サーバーレスネットワークエンドポイントグループの種類 | Cloud Functions |
関数名を選択 | adjust-server |
フロントエンドの設定
項目 | 設定内容 |
---|---|
名前 | adjust-server-frontend |
プロトコル | HTTP |
ネットワークサービス階層 | プレミアム |
IPバージョン | IPv4 |
IPアドレス | エフェメラル ( or 静的IPアドレス) |
ポート | 80 |
Cloud Load Balancing リソースが作成されたら、作成された IP アドレスにアクセスしてみましょう。
Cloud Functions のトリガーURLにアクセスした時と同様にログが出力されていればOKです。
$ curl http://${lb_ip_address}
Cloud Armor のポリシーを作成する
最後に、 Cloud Armor で Adjust の IP アドレスをホワイトリストに登録します。
Cloud Armor
> ポリシーを作成
から、ポリシーの設定を行います。
Adjust の IP アドレスは以下の公式ドキュメントを参照してください。
参考資料 > リスト > Adjustサーバー IP
ポリシーの設定
項目 | 設定内容 |
---|---|
名前 | adjust-server-policy |
デフォルトのルールアクション | 拒否 |
拒否ステータス | 403 (アクセス拒否) |
関数名を選択 | adjust-server |
ルールの追加
項目 | 設定内容 |
---|---|
モード | 基本モード |
一致 | x.x.x.x/24,x.x.x.x/24,... |
アクション | 許可 |
優先度 | 0 |
※ IPアドレスは最大で10個までしか指定できないので、複数のルールを追加します。
※ 優先度は重複できないので、新しいルールを追加する際は優先度をインクリメントしてください。
ターゲットへのポリシーの適用
項目 | 設定内容 |
---|---|
タイプ | ロードバランサ バックエンドサービス |
ターゲット | adjust-server-backend |
ポリシーが作成されたら、ロードバランサーのセキュリティ設定にadjust-server-policyを追加します。
Cloud Load Balancing
から adjust-server-lb の編集画面に遷移します。
バックエンドの構成
から adjust-server-backend を選択し、 セキュリティ
に adjust-server-policy を設定します。
これで Cloud Functions へのアクセスを Adjust の IP からのみ許可する設定ができました。
Adjust のコールバックURLを変更する
各リソースの作成が完了したら、 Adjust のリアルタイムコールバックの設定を更新しましょう。
http://${lb_ip_address}?app_id={app_id}&app_name={app_name}
今回は省略していますが、運用する際は以下の設定もやっておくと良いでしょう。
- Cloud DNS を使ってドメインを設定する
- 静的 IP を取得してロードバランサーのフロントエンドに設定する
- SSL/TLS 通信の設定
6. まとめ
Adjust のデータを Cloud Functions に送信して Cloud Logging へ流すための設計をまとめました。
簡易的に作るだけであれば Cloud Functions を使うだけで良いですが、実戦運用する際には IP 制限や負荷分散を考慮する必要があるので、 Cloud Load Balancing や Cloud Armor を併用する設計が良いと思います。
Author And Source
この問題について(Adjust のリアルタイムコールバックを Cloud Logging に流す), 我々は、より多くの情報をここで見つけました https://qiita.com/8kka/items/c1bf3bac5776bb1dae9d著者帰属:元の著者の情報は、元のURLに含まれています。著作権は原作者に属する。
Content is automatically searched and collected through network algorithms . If there is a violation . Please contact us . We will adjust (correct author information ,or delete content ) as soon as possible .