メインコンテンツまでスキップ

アカウントの同時使用デバイスの追跡

アクセス管理、セキュリティの確保、リソースの最適化が最優先されるアプリケーションでは、アカウントごとの同時デバイスやストリームの追跡が不可欠です。サブスクリプション・ベースのサービスでは、デバイスまたはストリームの制限を実施することで、コンテンツへの同時アクセスを指定されたデバイス数に制限します。通貨追跡はまた、不正な共有を防止することでアカウントのセキュリティをサポートし、潜在的な悪用からサービスを保護します。これはまた、リアルタイムの需要に基づいて動的にリソースを管理することにより、特にメディアやエンターテイメントなど、トラフィックの多いアプリケーションにおけるリソースの最適化を可能にします。

以下に示すパターンは、Momentoが複雑なインフラストラクチャを必要とせずにリアルタイム・セッション・モニタリングを提供する方法を示しています。

概要​

Momentoで同時実行を監視するには、接続されたプレイヤーから発信されるheartbeatsに依存します。サーバーコンポーネントは、Momentoのキャッシュ辞書を管理し、指定された間隔で一意のプレーヤーからのハートビートを追跡します。エンタイトルメントチェックの間に、最後の完全なインターバル辞書がフェッチされ、同時実行カウントが決定されます。

同時実行追跡の主なコンポーネントは以下の通りです：

  • Device - 各デバイスまたはストリームは、Momento Topicsを介してハートビートを送信します。
  • Momento
    • Cache - 各アカウントの最近のハートビートを、インターバルベースのキャッシュ辞書に格納します。
    • Auth - トークンにアカウントIDを直接エンコードして、プレイヤー用のセッショントークンを作成します。
  • Account - システムのユーザーアカウントを表します。

同時実行トラッカーの構築​

このパターンには4つのコンポーネントが必要です：

  • トークン自動販売機
  • デバイス・ハートビート
  • ハートビートハンドラ
  • 同時実行チェッカー

トークン自動販売機​

トークン自動販売機は、限定されたパーミッションを持つ短命のセッショントークンを払い出すパターンです。これはサーバー側のコンポーネントで、通常はAPIエンドポイントで、動的にトークンを生成します。以下は、セッショントークンを生成するために使用されるコードのスニペットです。このコードはAPIエンドポイントハンドラの中に記述する必要があります。

const scope = { permissions: [
  {
    role: 'publishonly',
    cache: 'video',
    topic: 'heartbeat'
  }
]};

const response = await authClient.generateDisposableToken(scope, ExpiresIn.minutes(30), { tokenId: accountId });
if(response.type === GenerateDisposableTokenResponse.Success){
  return { token: response.authToken };
}

上のスニペットでは、ユーザが heartbeat トピックにメッセージを 発行 できるように明示的なパーミッションを設定しています。これは、プレイヤーのハートビートがハンドラと通信する方法です。トークンは30分間有効で、ユーザーの accountId がトークンに埋め込まれています。埋め込まれたアカウントIDは、サーバ上のハートビート購読の引数として表示されます。

備考

実運用シナリオでは、このコードは既存の authZ メカニズムに組み込まれ、生成されたトークンを claim として返すかもしれません。ここでは、上記のコードスニペットの前に、ユーザが認証され、そのアカウント ID にアクセスでき、そのユーザが見ようとしているコンテンツを安全に識別できていることを前提としています。

デバイス・ハートビート​

トークン自動販売機が設置されたので、これをデバイスで使用して、定期的にハートビートを発行することができます。ハートビートには、ユースケースに応じて、メディア、プレーヤー、デバイスに関するあらゆる情報を含めることができます。この簡単なウォークスルーでは、最小限の情報を提供し、デバイスIDのみを含めることにします。

import React, { useEffect, useState, useMemo } from 'react';
import ReactDOM from 'react-dom/client';
import { TopicClient, CredentialProvider } from '@gomomento/sdk-web';

const HEARTBEAT_INTERVAL_MS = 5000;

function getMediaIdFromQuery() {
  const params = new URLSearchParams(window.location.search);
  return params.get('id');
}

function Device() {
  const [topicClient, setTopicClient] = useState(null);

  const mediaId = useMemo(() => getMediaIdFromQuery(), []);
  const deviceId = useMemo(() => {
    const savedDeviceId = localStorage.getItem('deviceId');
    if (savedDeviceId) return savedDeviceId;

    const newDeviceId = crypto.randomUUID();
    localStorage.setItem('deviceId', newDeviceId);
    return newDeviceId;
  }, []);

  const message = useMemo(() => JSON.stringify({ deviceId, mediaId }), [deviceId, mediaId]);

  useEffect(() => {
    async function initTopicClient() {
      const response = await fetch('http://localhost:3000/tokens', {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
        },
        body: JSON.stringify({ accountId: 'account-id' }),
      });
      if (response.ok) {
        const { token } = await response.json();
        const topicClient = new TopicClient({
          credentialProvider: CredentialProvider.fromString(token),
        });
        setTopicClient(topicClient);
      }
    }

    initTopicClient();
  }, [mediaId]);

  useEffect(() => {
    if (topicClient) {
      const intervalId = setInterval(() => {
        topicClient.publish('video', 'heartbeat', message);
      }, HEARTBEAT_INTERVAL_MS);

      return () => clearInterval(intervalId);
    }
  }, [topicClient, mediaId, message]);

  return (
    <div>
      <h2>Device {deviceId}: {topicClient ? 'Connected' : 'Not Connected'}</h2>
    </div>
  );
}

const root = ReactDOM.createRoot(document.getElementById('root'));
root.render(<Device />);

上記の例では、プレーヤhtmlにはハートビート・ロジックしか含まれていません。トークンを取得するために、ローカルで実行されているAPIエンドポイントの後ろに置いたステップ1のトークン自動販売機を呼び出します。プレーヤーがトークンを取得すると、デバイスIDとメディアIDをheartbeatトピックに公開し始めます。ハートビートは5秒ごとに送信されるので、ハートビートハンドラーはアクティブなインスタンスを追跡できます。

デバイスのハートビートのコードで注意すべき点が2つあります：

  1. トークン自動販売機に供給されるアカウントIDはハードコードされています。
  2. Momento HTTP APIを呼び出す場合、ベースURLはregion basedです。プレースホルダを、使用するケースに適したリージョンのエンドポイントに置き換えてください。Momento SDKを使用する場合、リージョン処理は管理されます。

メダル自動販売機の完全な例については、このチュートリアルをご覧ください.

ハートビートハンドラ​

特定のアカウントのデバイスは、一連のキャッシュ辞書で追跡されます。一意のキャッシュ・ディクショナリは、指定された時間間隔にわたってデバイスのハートビートを追跡するために使用されます。時間間隔は、ビジネス要件に応じて変えることができます。この例では、コンカレンシーを1分に1回評価します。

インターバル・ベースの辞書の命名規則は {accountId}-{intervalTime} です。インターバル時間を計算するには、指定された分の時間を数値で表し、切り捨てます。

function getIntervalMarker(minutesBack = 0) {
  const now = new Date();
  now.setTime(now.getTime() - minutesBack * 60000);
  now.setSeconds(0, 0);
  return now.getTime();
}

デバイスのハートビート数を追跡するキャッシュ・キーを作成するには、上記の関数の値をユーザのアカウントIDの末尾に追加します。この方法でキーを作成すると、インターバルごとに 専用のキャッシュ・アイテム が提供されます。適切なtime to live (TTL)と組み合わせることで、キャッシュアイテムは自動的にクリーンアップされ、このパターンに必要なコードが簡素化されます。

// Get the account id through your business logic
const accountId = getAccountId(req);
const { deviceId } = req.body;
const key = `${accountId}-${getIntervalMarker()}`;

await cacheClient.dictionaryIncrement('video', key, deviceId, 1);

ハートビートが受信されると、デバイスIDが辞書に値として格納され、カウントがインクリメントされる。辞書にはインターバル長の2倍のTTLが設定されているため、データが不要になると自動的にクリーンアップされます。

さて、データが保存されたので、何台のデバイスがアクティブにスチームしているかをチェックするコードに移りましょう。

同時実行チェッカー​

最後に、同時実行チェッカーがある。多くの場合、entitlement checkの一部として組み込まれるこのロジックは、ハートビート辞書を読み取り、アカウントが許容限度を超えているかどうかを判断します。同時実行をチェックするには、前のインターバルから辞書の長さを取得し、エントリ数を数えます。

async function getConcurrentDeviceCount(accountId) {
  const interval = getIntervalMarker(1);
  const intervalKey = `${accountId}-${interval}`;
  let deviceCount = 0;
  const response = await cacheClient.dictionaryLength('video', intervalKey);
  if(response.type === CacheDictionaryLengthResponse.Hit){
    deviceCount = response.value();
  }
  return deviceCount;
}

この関数は、前のステップで作成した getIntervalMarker メソッドを使用して最後のインターバルの時間を取得し、Momento Cache を呼び出して辞書のエントリ数を確認します。覚えておいてほしいのは、ハートビートを報告した各デバイスは辞書のエントリとしてカウントされるので、長さは直接、同時プレーヤーの数に対応します。

この値は呼び出し元に返され、そこから先は標準的なビジネスロジックに任されます。

ヒント

このパターンの完全な実例と、メディア・ストリーミングの他の実用的なパターンについては、私たちのdemo on GitHubをチェックしてください！