AWS AppSync Eventsとは

AWS AppSync Eventsは、接続やリソースのスケーリングを管理することなく、何百万ものサブスクライバにリアルタイムのイベントデータをブロードキャストできる、安全でパフォーマンスの高いサーバーレスWebSocket APIを作成できるサービスです。AWS AppSync Eventsを使えば、APIコードを書く必要がないので、リアルタイムのWebアプリケーションやモバイル体験を短時間で作成できます。

AWS AppSync Eventsを利用することで、メッセージ変換とブロードキャスト、パブリッシュとサブスクライブ認証、ログとメトリクスの作成などのタスクを AWS にオフロードすることができます。

AWS AppSyncのEvent APIを使用すると、以下のネットワーク通信タイプを有効にすることができます。

ユニキャスト
マルチキャスト
ブロードキャスト
バッチパブリッシングとメッセージング

AWS AppSync Eventsを利用することで、ライブチャット、リアルタイム通知、ライブコメントなどの双方向のインタラクティブなアプリケーションの開発が容易になります。AWS AppSync Events は以下の機能を提供します。

WebSocket接続の自動管理とスケーリング
多数のサブスクライバへのイベントブロードキャストのビルトインサポート
柔軟なイベントフィルタリングと変換機能
きめ細かな認証と認可
イベントドリブンアーキテクチャのための他のAWSサービスや外部システムとのシームレスな統合

AWS AppSync Eventsの機能

WebSocketとHTTPのサポート

クライアントはHTTP経由でイベントを発行し、WebSocketを使用してチャンネルをサブスクライブすることができます。
Event API は、リアルタイムとpub/sub機能を可能にするWebSocketエンドポイントを提供します。

チャンネル名前空間とチャンネル

イベントは、名前空間の下にグループ化されたチャンネルにパブリッシュされます。
名前空間では、その名前空間内のすべてのチャンネルに適用される認証と認可のルールとサーバーレス関数を定義できます。

名前空間ハンドラ

以下の2種類のハンドラを使用して、パブリッシュおよびサブスクライブアクションに応答して実行される関数を設定できます。

OnPublish - イベントがチャンネルにパブリッシュされたときに実行され、イベントの変換、フィルタリング、拒否を行います。
OnSubscribe - クライアントがチャネルをサブスクライブしたときに実行され、その振る舞いをカスタマイズしたりサブスクライブリクエストを拒否したりできます。

柔軟な認証と認可

Event APIは様々な認証メカニズム（APIキー、IAM、Amazon Cognito、OIDC、Lambdaオーソライザー）をサポートしており、APIレベルで設定し、チャンネル名前空間レベルでカスタマイズすることができます。

チャンネルサブスクライブ

クライアントはサブスクライブしているチャンネルのイベントを受信します。

ワイルドカードチャンネルサブスクライブ

クライアントは、ワイルドカード構文（「namespace/channel/*」など）を使用して、関連するチャンネルのグループをサブスクライブすることができます。

スケーラブルなイベントブロードキャスト

Event APIは、大量の同時接続を処理するために自動的に拡張され、サブスクライブされたすべてのクライアントに効率的にイベントをブロードキャストすることができます。

AWS エコシステムとの統合

AWS AppSync Eventsは、Amazon CloudWatch Logs、CloudWatch metrics、AWS WAFのような他のAWSサービスと統合します。Amazon EventBridgeやAWS Lambdaのようなサービスから直接パブリッシュすることで、イベントドリブンアーキテクチャを簡単に実装できます。Amazon Cognitoは認可タイプとして直接サポートされています。

AWS AppSync Eventsの価格について

AWS AppSync Eventsを利用する場合、最低料金や強制的なサービス利用はなく、利用した分だけの支払いになります。詳細については、AWS AppSyncの価格を参照してください。

AWS AppSync Event APIを作成してみた

AWS AppSync Event API を作成し、クライアントからアクセスすることで、AWS AppSync Events をすぐに使い始めることができます。AWS AppSync Events Developer Guideの記述に従って、AWS AppSyncコンソールでAWS AppSync Event APIを作成する手順を説明します。

AWS AppSync Event API の作成

AWS AppSync Events で、アプリケーションのリアルタイム機能を実現するためのEvent APIを作成します。ここでは、デフォルトのチャンネル名前空間を持つAPIを作成します。その後、AWS AppSyncコンソールを使用してメッセージを発行し、名前空間内のチャンネルに送信されたメッセージを購読します。

ステップ 1: AWS AppSyncコンソールを使用してイベントAPIを作成する

AWS Management Consoleにサインインし、AWS AppSyncコンソールを開きます。
AWS AppSyncコンソールの[API types]で、Event APIを選択し、[Event APIを作成]を選択します。
[Event APIを作成]ページの [APIの詳細] セクションでAPI名にAPIの名前を入力し、[作成]を選択します。
APIが作成されます。APIは、接続、パブリッシュ、サブスクライブアクションの認証モードとしてAPI Keyで構成され、APIキーが作成されます。default" という名前のデフォルト・チャネル・ネームスペースも作成されます。

認可のカスタマイズの詳細については、Configuring authorization and authentication to secure Event APIを参照してください。チャンネル名前空間についての詳細は、Understanding channel namespacesを参照してください。

ステップ2: 最初のイベントをパブリッシュし、受信登録する

以下の手順でイベントを発行します。

AWS AppSyncコンソールで、ステップ 1で作成したEvent APIの[Pub/Subエディタ]タブを選択します。
[パブリッシュ]セクションで、[チャンネル]の[名前空間を選択]のテキストボックスにdefaultと入力し、2番目のテキストボックスに /messagesと入力します。
コードエディタで、以下のJSONペイロードを入力します。

[{"message": "Hello world!"}]

[パブリッシュ]をクリックします。
パブリッシャーのログテーブルに以下のような応答が表示され、成功が確認されます。

{
  "channel": "default/messages",
  "events": [
    {
      "message": "Hello world!"
    }
  ]
}

次の手順で、メッセージの受信を登録します。

Amplify Eventクライアントの実装

ViteとAmplifyクライアントを使用してReactアプリを作成します。そして、このAmplifyクライアントを使用して、メッセージのパブリッシュとサブスクライブを行います。

AWS AppSync Event APIには、任意のHTTPおよびWebSocketクライアントを使用して接続でき、JavaScript用のAmplifyクライアントも使用できます。ここでは、AWS AppSync Events Developer Guideの手順に従って、JavaScript ReactアプリケーションからEvent APIに接続する方法を説明します。

ViteでReactアプリをデプロイする

ローカルの作業環境から、ターミナルウィンドウで以下のコマンドを実行し、React用の新しいViteアプリを作成します。
```
npm create vite@latest appsync-events-app -- --template react
```
以下のコマンドを実行して、appsync-events-appディレクトリに移動し、依存関係とAmplifyライブラリをインストールします。
```
cd appsync-events-app
npm install
npm install aws-amplify
```
別のターミナル・ウィンドウを開き、appsync-events-appディレクトリにcdします。以下のコマンドを実行し、devモードでサーバーを起動します。
```
npm run dev
```
ブラウザでlocalhostの指定のポートを開くとReactアプリケーションが表示されます。

Amplifyクライアントの設定

AWS Management Console にサインインし、AWS AppSyncコンソールを開きます。
上記で作成したEvent APIの[統合]タブを開きます。
[設定をダウンロード]をクリックして設定ファイルをダウンロードします。
amplify_outputs.jsonファイルをプロジェクトのsrcディレクトリに保存します。設定ファイルは以下のようになります。

{
  "API": {
    "Events": {
      "endpoint": "https://xxxx.appsync-api.us-west-2.amazonaws.com/event",
      "region": "us-west-2",
      "defaultAuthMode": "apiKey",
      "apiKey": "xxxxx..."
    }
  }
}

重要
defaultAuthModeはAPI_KEYではなく、apiKeyに設定する必要があります。

チャンネルに接続し、メッセージを受信する

App.jsxファイルを以下のコードで更新します。

import { useEffect, useState, useRef } from 'react'
import './App.css'

import { Amplify } from 'aws-amplify'
import { events } from 'aws-amplify/data'
import config from './amplify_outputs.json'

Amplify.configure(config)

export default function App() {
  const [messages, setMessages] = useState([])
  const [room, setRoom] = useState('')
  const counterRef = useRef(null)

  useEffect(() => {
    if (!room || !room.length) {
      return
    }
    let timeoutID
    const pr = events.connect(`/default/${room}`)
    pr.then((channel) => {
      channel.subscribe({
        next: (data) => {
          setMessages((messages) => [...messages, data.message])
          if (timeoutID) {
            clearTimeout(timeoutID);
          }
          counterRef.current?.classList.add('animate-bounce')
          timeoutID = setTimeout(() => {
            counterRef.current?.classList.remove('animate-bounce')
          }, 3000);
        },
        error: (value) => console.error(value),
      })
    })

    return () => {
      pr?.then((channel) => channel?.close())
    }
  }, [room])

  return (
    <div className='max-w-screen-md mx-auto'>
      <h2 className='my-4 p-4 font-semibold text-xl'>AppSync Events - Messages</h2>
      <button
        type="button"
        className='border rounded-md px-4 py-2 items-center text-sm font-medium transition-colors focus-visible:outline-none focus-visible:ring-1 focus-visible:ring-ring disabled:pointer-events-none disabled:opacity-50 bg-sky-200  shadow hover:bg-sky-200/90'
        onClick={() => {
          const room = prompt('Room:')
          if (room && room.length) {
            setMessages([])
            setRoom(room.trim().replace(/\W+/g, '-'))
          }
        }}
      >
        set room
      </button>
      <div className='my-4 border-b-2  border-sky-500 py-1 flex justify-between'>
        <div>
          {room ? (
            <span>
              Currently in room: <b>{room}</b>
            </span>
          ) : (
            <span>Pick a room to get started</span>
          )}
        </div>
        <div className='flex items-center uppercase text-xs tracking-wider font-semibold'>
          <div className='mr-2'>Messages count:</div>
          <span ref={counterRef} className='transition-all inline-flex items-center rounded-md bg-sky-100 px-2.5 py-0.5 text-xs font-medium text-sky-900'>{messages.length}</span></div>
      </div>
      <section id="messages" className='space-y-2'>
        {messages.map((message, index) => (
          <div
            key={index}
            className='border-b py-1 flex justify-between px-2'
          ><div>
              {message}
            </div>
            <div> </div>
          </div>
        ))}
      </section>
    </div>
  )
}

ブラウザでアプリを開き、[set room]ボタンを選択してルームをgreetingsに設定する。
AWS AppSyncコンソールを開き、APIの[Pub/Subエディタ]タブに移動します。
チャンネルを /default/greetingsに設定します。default名前空間を選択し、残りのパスを/greetingsに設定します。
イベントを送信するために、エディタに以下を貼り付けます。
```
[
    {
        "message": "hello world!"
    }
]
```

アプリにメッセージが表示されるはずです。

別の部屋を選択するために、もう一度set roomボタンを選択します。Pub/Sub Editorで別のイベントを/default/greetingsチャンネルに送信します。アプリにそのメッセージは表示されません。

アプリからメッセージを送る

App.jsxを開き、App関数の先頭に以下のコードを追加する。

const [message, setMessage] = useState('')

同じファイルで、最後のsection要素を探し、その次の要素として以下のコードを追加する。

<section>
        <form
          disabled={!room}
          className='w-full flex justify-between mt-8'
          onSubmit={async (e) => {
            e.preventDefault()
            const event = { message }
            setMessage('')
            await events.post(`/default/${room}`, event)
          }}
        >
          <input
            type="text"
            name="message"
            placeholder="Message:"
            className='flex flex-1 rounded-md border border-input px-3 py-1 h-9 text-sm shadow-sm transition-colors focus-visible:outline-none focus-visible:ring-1 focus-visible:ring-ring disabled:cursor-not-allowed disabled:opacity-50 bg-transparent'
            value={message}
            disabled={!room}
            onChange={(e) => setMessage(e.target.value)}
          />
          <button
            type="submit"
            className='ml-4 border rounded-md px-4 flex items-center text-sm font-medium transition-colors focus-visible:outline-none focus-visible:ring-1 focus-visible:ring-ring disabled:pointer-events-none disabled:opacity-50 bg-sky-200  shadow hover:bg-sky-200/90'
            disabled={!room || !message || !message.length}>
            <svg xmlns="http://www.w3.org/2000/svg" className='size-4' width="24" height="24" viewBox="0 0 24 24" fill="none" stroke="currentColor" strokeWidth="2" strokeLinecap="round" strokeLinejoin="round"><path d="M14.536 21.686a.5.5 0 0 0 .937-.024l6.5-19a.496.496 0 0 0-.635-.635l-19 6.5a.5.5 0 0 0-.024.937l7.93 3.18a2 2 0 0 1 1.112 1.11z" /><path d="m21.854 2.147-10.94 10.939" /></svg>
          </button>
        </form>
      </section>

これでアプリから直接、選択した部屋にメッセージを送れるようになりました。

まとめ

いかがでしょうか。AWS AppSync Eventsを利用することで、リアルタイムな双方向のアプリケーションの開発において、開発者の実装の負荷を軽減して容易に構築できることが理解できたと思います。今回はre:Invent 2024直前に新たにリリースされたAWS AppSync Eventsについて簡単に紹介しましたが、この記事が何かのお役に立てば幸いです。

免責

本投稿は個人の意見であり、所属する企業や団体は関係ありません。
また掲載しているサンプルプログラム等の動作に関しても一切保証しておりません。