IdMappingWorkflow

Source: src/AWS/EntityResolution/IdMappingWorkflow.ts

An AWS Entity Resolution ID mapping workflow — a data-processing job definition that translates record identifiers between a SOURCE and a TARGET ID namespace, using rule-based matching or a provider service.

The workflow definition itself is cheap and instant; a mapping RUN (StartIdMappingJob) processes the full input and takes many minutes.

Creating ID Mapping Workflows

import * as AWS from "alchemy/AWS";

const workflow = yield* AWS.EntityResolution.IdMappingWorkflow("Map", {
  inputSourceConfig: [
    { inputSourceARN: source.idNamespaceArn, type: "SOURCE" },
    { inputSourceARN: target.idNamespaceArn, type: "TARGET" },
  ],
  idMappingTechniques: {
    idMappingType: "RULE_BASED",
    ruleBasedProperties: {
      ruleDefinitionType: "TARGET",
      attributeMatchingModel: "ONE_TO_ONE",
      recordMatchingModel: "ONE_SOURCE_TO_ONE_TARGET",
    },
  },
  outputSourceConfig: [
    { outputS3Path: `s3://${bucket.bucketName}/idmapping/` },
  ],
  roleArn: role.roleArn,
});