Lambda 関数を使用したカスタムデータアクセス

import {
  type ClientSchema,
  a,
  defineData,
  defineFunction,
} from '@aws-amplify/backend';

const schema = a.schema({
  Todo: a
    .model({
      content: a.string(),
    })
    // ステップ 1
    // カスタム認可ルールを使用する必要があるモデル / フィールドを指定します
    .authorization(allow => [allow.custom()]),
});

export type Schema = ClientSchema<typeof schema>;

export const data = defineData({
  schema,
  authorizationModes: {
    defaultAuthorizationMode: 'lambda',
    // ステップ 2
    // カスタム認可ルールに使用する関数を渡します
    lambdaAuthorizationMode: {
      function: defineFunction({
        entry: './custom-authorizer.ts',
      }),
      // (オプション) ステップ 3
      // トークンの有効期限を設定します
      timeToLiveInSeconds: 300,
    },
  },
});

import { generateClient } from 'aws-amplify/data';
import type { Schema } from '../amplify/data/resource'; // Path to your backend resource definition

const client = generateClient<Schema>();

const { errors, data: newTodo } = await client.models.Todo.create(
  {
    content: 'My new todo',
  },
Copy highlighted code example
  {
    authMode: 'lambda',
  }
);

// amplify/data/custom-authorizer.ts

// This is sample code. Update this to suite your needs
import type { AppSyncAuthorizerHandler } from 'aws-lambda'; // types imported from @types/aws-lambda

type ResolverContext = {
  userid: string;
  info: string;
  more_info: string;
};

export const handler: AppSyncAuthorizerHandler<ResolverContext> = async (
  event
) => {
  console.log(`EVENT: ${JSON.stringify(event)}`);
  const {
    authorizationToken,
    requestContext: { apiId, accountId }
  } = event;
  const response = {
    isAuthorized: authorizationToken === 'custom-authorized',
    resolverContext: {
      // eslint-disable-next-line spellcheck/spell-checker
      userid: 'user-id',
      info: 'contextual information A',
      more_info: 'contextual information B'
    },
    deniedFields: [
      `arn:aws:appsync:${process.env.AWS_REGION}:${accountId}:apis/${apiId}/types/Event/fields/comments`,
      `Mutation.createEvent`
    ],
    ttlOverride: 300
  };
  console.log(`RESPONSE: ${JSON.stringify(response, null, 2)}`);
  return response;
};

{
    "authorizationToken": "ExampleAuthToken123123123", # クライアントによって指定された認可トークン
    "requestContext": {
        "apiId": "aaaaaa123123123example123", # AppSync API ID
        "accountId": "111122223333", # AWS アカウント ID
        "requestId": "f4081827-1111-4444-5555-5cf4695f339f",
        "queryString": "mutation CreateEvent {...}\n\nquery MyQuery {...}\n", # GraphQL クエリ
        "operationName": "MyQuery", # GraphQL 操作名
        "variables": {} # 操作に指定された追加の変数
    }
}

{
  // 必須
  "isAuthorized": true, // "false" の場合は UnauthorizedException が発生し、アクセスが拒否されます
  "resolverContext": { "banana": "very yellow" }, // VTL リゾルバーテンプレートで $ctx.identity.resolverContext として表示される JSON オブジェクト

  // オプション
  "deniedFields": ["TypeName.FieldName"], // クライアントに返されるときにフィールドを「null」に強制します
  "ttlOverride": 10 // レスポンスをキャッシュする秒数です。「amplify update api」で指定されたデフォルトをオーバーライドします
}