カスタムクエリとミューテーションの設定

const echoLambda = new lambda.Function(this, 'EchoLambda', {
  functionName: 'echofunction', // MAKE SURE THIS MATCHES THE @function's "name" PARAMETER
  code: lambda.Code.fromAsset(path.join(__dirname, 'handlers/echo')),
  handler: 'index.handler',
  runtime: lambda.Runtime.NODEJS_18_X
});

const amplifyApi = new AmplifyGraphqlApi(this, 'AmplifyCdkGraphQlApi', {
  definition: AmplifyGraphqlDefinition.fromFiles(
    path.join(__dirname, 'schema.graphql')
  ),
  authorizationModes: {
    defaultAuthorizationMode: 'API_KEY',
    apiKeyConfig: {
      expires: cdk.Duration.days(30)
    }
  }
});

type Query {
  echo(msg: String): String @function(name: "echofunction")
}

const coolLambdaFunction = new lambda.Function(this, 'MyCoolLambdaFunction', {
  code: lambda.Code.fromAsset(path.join(__dirname, 'handlers/echo')),
  handler: 'index.handler',
  runtime: lambda.Runtime.NODEJS_18_X
});

const amplifyApi = new AmplifyGraphqlApi(this, 'AmplifyCdkGraphQlApi', {
  definition: AmplifyGraphqlDefinition.fromFiles(
    path.join(__dirname, 'schema.graphql')
  ),
  authorizationModes: {
    defaultAuthorizationMode: 'API_KEY',
    apiKeyConfig: {
      expires: cdk.Duration.days(30)
    }
  },
  functionNameMap: {
    echofunction: coolLambdaFunction // Remap the function name to any function you define or reference within CDK.
  }
});

type Query {
  echo(msg: String): String @function(name: "echofunction")
}

import * as cdk from 'aws-cdk-lib';
import * as AmplifyHelpers from '@aws-amplify/cli-extensibility-helper';
import * as appsync from 'aws-cdk-lib/aws-appsync';
import { AmplifyDependentResourcesAttributes } from '../../types/amplify-dependent-resources-ref';
import { Construct } from 'constructs';

const requestVTL = `
<YOUR CUSTOM VTL REQUEST MAPPING TEMPLATE HERE>
`;
const responseVTL = `
<YOUR CUSTOM VTL RESPONSE MAPPING TEMPLATE HERE>
`;

export class cdkStack extends cdk.Stack {
  constructor(
    scope: Construct,
    id: string,
    props?: cdk.StackProps,
    amplifyResourceProps?: AmplifyHelpers.AmplifyResourceProps
  ) {
    super(scope, id, props);
    /* Do not remove - Amplify CLI automatically injects the current deployment environment in this input parameter */
    new cdk.CfnParameter(this, 'env', {
      type: 'String',
      description: 'Current Amplify CLI env name'
    });

    // Access other Amplify Resources
    const retVal: AmplifyDependentResourcesAttributes =
      AmplifyHelpers.addResourceDependency(
        this,
        amplifyResourceProps.category,
        amplifyResourceProps.resourceName,
        [
          {
            category: 'api',
            resourceName: '<YOUR-API-NAME>'
          }
        ]
      );

    const resolver = new appsync.CfnResolver(this, 'custom-resolver', {
      // apiId: retVal.api.new.GraphQLAPIIdOutput,
      // https://github.com/aws-amplify/amplify-cli/issues/9391#event-5843293887
      // If you use Amplify you can access the parameter via Ref since it's a CDK parameter passed from the root stack.
      // Previously the ApiId is the variable Name which is wrong , it should be variable value as below
      apiId: cdk.Fn.ref(retVal.api.replaceWithAPIName.GraphQLAPIIdOutput),
      fieldName: 'querySomething',
      typeName: 'Query', // Query | Mutation | Subscription
      requestMappingTemplate: requestVTL,
      responseMappingTemplate: responseVTL,
      dataSourceName: 'TodoTable' // DataSource name
    });
  }
}

import * as cdk from 'aws-cdk-lib';
import * as AmplifyHelpers from '@aws-amplify/cli-extensibility-helper';
import * as appsync from 'aws-cdk-lib/aws-appsync';
import { AmplifyDependentResourcesAttributes } from '../../types/amplify-dependent-resources-ref';
import { Construct } from 'constructs';

const beforeMappingVTL = `
<YOUR CUSTOM VTL REQUEST MAPPING TEMPLATE HERE>
`;
const afterMappingVTL = `
<YOUR CUSTOM VTL RESPONSE MAPPING TEMPLATE HERE>
`;
const function1requestVTL = `
<YOUR CUSTOM VTL FUNCTION 1 REQUEST MAPPING TEMPLATE HERE>
`;
const function1responseVTL = `
<YOUR CUSTOM VTL FUNCTION 1 RESPONSE MAPPING TEMPLATE HERE>
`;
const function2requestVTL = `
<YOUR CUSTOM VTL FUNCTION 2 REQUEST MAPPING TEMPLATE HERE>
`;
const function2responseVTL = `
<YOUR CUSTOM VTL FUNCTION 2 RESPONSE MAPPING TEMPLATE HERE>
`;
export class cdkStack extends cdk.Stack {
  constructor(
    scope: Construct,
    id: string,
    props?: cdk.StackProps,
    amplifyResourceProps?: AmplifyHelpers.AmplifyResourceProps
  ) {
    super(scope, id, props);
    /* Do not remove - Amplify CLI automatically injects the current deployment environment in this input parameter */
    new cdk.CfnParameter(this, 'env', {
      type: 'String',
      description: 'Current Amplify CLI env name'
    });

    // Access other Amplify Resources
    const retVal: AmplifyDependentResourcesAttributes =
      AmplifyHelpers.addResourceDependency(
        this,
        amplifyResourceProps.category,
        amplifyResourceProps.resourceName,
        [
          {
            category: 'api',
            resourceName: '<YOUR-API-NAME>'
          }
        ]
      );

    const function1 = new appsync.CfnFunctionConfiguration(this, 'function1', {
      apiId: cdk.Fn.ref(retVal.api.replaceWithAPIName.GraphQLAPIIdOutput),
      dataSourceName: 'NONE_DS', // DataSource name
      functionVersion: '2018-05-29',
      name: 'function1',
      requestMappingTemplate: function1requestVTL,
      responseMappingTemplate: function1responseVTL
    });

    const function2 = new appsync.CfnFunctionConfiguration(this, 'function2', {
      apiId: cdk.Fn.ref(retVal.api.replaceWithAPIName.GraphQLAPIIdOutput),
      dataSourceName: 'TodoTable', // DataSource name
      functionVersion: '2018-05-29',
      name: 'function2',
      requestMappingTemplate: function2requestVTL,
      responseMappingTemplate: function2responseVTL
    });

    const resolver = new appsync.CfnResolver(this, 'pipeline-resolver', {
      apiId: cdk.Fn.ref(retVal.api.replaceWithAPIName.GraphQLAPIIdOutput),
      fieldName: 'querySomething',
      typeName: 'Query', // Query | Mutation | Subscription
      kind: 'PIPELINE',
      pipelineConfig: {
        functions: [function1.attrFunctionId, function2.attrFunctionId]
      },
      requestMappingTemplate: beforeMappingVTL,
      responseMappingTemplate: afterMappingVTL
    });
  }
}

requestMappingTemplate: appsync.MappingTemplate.fromFile(path.join(__dirname, "..", "Query.testColin.req.vtl")).renderTemplate(),
responseMappingTemplate: appsync.MappingTemplate.fromFile(path.join(__dirname, "..", "Query.testColin.res.vtl")).renderTemplate(),