Exemplos do AWS Entity Resolution usando o SDK para JavaScript (v3) - Exemplos de código do AWS SDK

Há mais exemplos do AWS SDK disponíveis no repositório do GitHub Documento de Exemplos do AWS SDK.

Exemplos do AWS Entity Resolution usando o SDK para JavaScript (v3)

Os exemplos de código a seguir mostram como realizar ações e implementar cenários comuns usando o AWS SDK para JavaScript (v3) com o AWS Entity Resolution.

Ações são trechos de código de programas maiores e devem ser executadas em contexto. Embora as ações mostrem como chamar perfis de serviço individuais, você pode ver as ações no contexto em seus cenários relacionados.

Cada exemplo inclui um link para o código-fonte completo, em que você pode encontrar instruções sobre como configurar e executar o código.

Conceitos básicos

O exemplo de código a seguir mostra como começar a usar o AWS Entity Resolution.

SDK para JavaScript (v3)
nota

Há mais no GitHub. Encontre o exemplo completo e veja como configurar e executar no AWS Code Examples Repository.

import { fileURLToPath } from "node:url"; import { EntityResolutionClient, ListMatchingWorkflowsCommand, } from "@aws-sdk/client-entityresolution"; export const main = async () => { const region = "eu-west-1"; const erClient = new EntityResolutionClient({ region: region }); try { const command = new ListMatchingWorkflowsCommand({}); const response = await erClient.send(command); const workflowSummaries = response.workflowSummaries; for (const workflowSummary of workflowSummaries) { console.log(`Attribute name: ${workflowSummaries[0].workflowName} `); } if (workflowSummaries.length === 0) { console.log("No matching workflows found."); } } catch (error) { console.error( `An error occurred in listing the workflow summaries: ${error.message} \n Exiting program.`, ); return; } };
Tópicos

Ações

O código de exemplo a seguir mostra como usar CreateMatchingWorkflow.

SDK para JavaScript (v3)
nota

Há mais no GitHub. Encontre o exemplo completo e veja como configurar e executar no AWS Code Examples Repository.

//The default inputs for this demo are read from the ../inputs.json. import { fileURLToPath } from "node:url"; import { CreateMatchingWorkflowCommand, EntityResolutionClient, } from "@aws-sdk/client-entityresolution"; import data from "../inputs.json" with { type: "json" }; const region = "eu-west-1"; const erClient = new EntityResolutionClient({ region: region }); export const main = async () => { const createMatchingWorkflowParams = { roleArn: `${data.inputs.roleArn}`, workflowName: `${data.inputs.workflowName}`, description: "Created by using the AWS SDK for JavaScript (v3).", inputSourceConfig: [ { inputSourceARN: `${data.inputs.JSONinputSourceARN}`, schemaName: `${data.inputs.schemaNameJson}`, applyNormalization: false, }, { inputSourceARN: `${data.inputs.CSVinputSourceARN}`, schemaName: `${data.inputs.schemaNameCSV}`, applyNormalization: false, }, ], outputSourceConfig: [ { outputS3Path: `s3://${data.inputs.myBucketName}/eroutput`, output: [ { name: "id", }, { name: "name", }, { name: "email", }, { name: "phone", }, ], applyNormalization: false, }, ], resolutionTechniques: { resolutionType: "ML_MATCHING" }, }; try { const command = new CreateMatchingWorkflowCommand( createMatchingWorkflowParams, ); const response = await erClient.send(command); console.log( `Workflow created successfully.\n The workflow ARN is: ${response.workflowArn}`, ); } catch (caught) { console.error(caught.message); throw caught; } };

O código de exemplo a seguir mostra como usar CreateSchemaMapping.

SDK para JavaScript (v3)
nota

Há mais no GitHub. Encontre o exemplo completo e veja como configurar e executar no AWS Code Examples Repository.

//The default inputs for this demo are read from the ../inputs.json. import { fileURLToPath } from "node:url"; import { CreateSchemaMappingCommand, EntityResolutionClient, } from "@aws-sdk/client-entityresolution"; import data from "../inputs.json" with { type: "json" }; const region = "eu-west-1"; const erClient = new EntityResolutionClient({ region: region }); export const main = async () => { const createSchemaMappingParamsJson = { schemaName: `${data.inputs.schemaNameJson}`, mappedInputFields: [ { fieldName: "id", type: "UNIQUE_ID", }, { fieldName: "name", type: "NAME", }, { fieldName: "email", type: "EMAIL_ADDRESS", }, ], }; const createSchemaMappingParamsCSV = { schemaName: `${data.inputs.schemaNameCSV}`, mappedInputFields: [ { fieldName: "id", type: "UNIQUE_ID", }, { fieldName: "name", type: "NAME", }, { fieldName: "email", type: "EMAIL_ADDRESS", }, { fieldName: "phone", type: "PROVIDER_ID", subType: "STRING", }, ], }; try { const command = new CreateSchemaMappingCommand( createSchemaMappingParamsJson, ); const response = await erClient.send(command); console.log("The JSON schema mapping name is ", response.schemaName); } catch (error) { console.log("error ", error.message); } };
  • Consulte detalhes da API em CreateSchemaMapping na Referência de API do AWS SDK para JavaScript.

O código de exemplo a seguir mostra como usar DeleteMatchingWorkflow.

SDK para JavaScript (v3)
nota

Há mais no GitHub. Encontre o exemplo completo e veja como configurar e executar no AWS Code Examples Repository.

//The default inputs for this demo are read from the ../inputs.json. import { fileURLToPath } from "node:url"; import { DeleteMatchingWorkflowCommand, EntityResolutionClient, } from "@aws-sdk/client-entityresolution"; import data from "../inputs.json" with { type: "json" }; const region = "eu-west-1"; const erClient = new EntityResolutionClient({ region: region }); export const main = async () => { try { const deleteWorkflowParams = { workflowName: `${data.inputs.workflowName}`, }; const command = new DeleteMatchingWorkflowCommand(deleteWorkflowParams); const response = await erClient.send(command); console.log("Workflow deleted successfully!", response); } catch (error) { console.log("error ", error); } };

O código de exemplo a seguir mostra como usar DeleteSchemaMapping.

SDK para JavaScript (v3)
nota

Há mais no GitHub. Encontre o exemplo completo e veja como configurar e executar no AWS Code Examples Repository.

//The default inputs for this demo are read from the ../inputs.json. import { fileURLToPath } from "node:url"; import { DeleteSchemaMappingCommand, EntityResolutionClient, } from "@aws-sdk/client-entityresolution"; import data from "../inputs.json" with { type: "json" }; const region = "eu-west-1"; const erClient = new EntityResolutionClient({ region: region }); export const main = async () => { const deleteSchemaMapping = { schemaName: `${data.inputs.schemaNameJson}`, }; try { const command = new DeleteSchemaMappingCommand(deleteSchemaMapping); const response = await erClient.send(command); console.log("Schema mapping deleted successfully. ", response); } catch (error) { console.log("error ", error); } };
  • Consulte detalhes da API em DeleteSchemaMapping na Referência de API do AWS SDK para JavaScript.

O código de exemplo a seguir mostra como usar GetMatchingJob.

SDK para JavaScript (v3)
nota

Há mais no GitHub. Encontre o exemplo completo e veja como configurar e executar no AWS Code Examples Repository.

//The default inputs for this demo are read from the ../inputs.json. import { fileURLToPath } from "node:url"; import { GetMatchingJobCommand, EntityResolutionClient, } from "@aws-sdk/client-entityresolution"; import data from "../inputs.json" with { type: "json" }; const region = "eu-west-1"; const erClient = new EntityResolutionClient({ region: region }); export const main = async () => { async function getInfo() { const getJobInfoParams = { workflowName: `${data.inputs.workflowName}`, jobId: `${data.inputs.jobId}`, }; try { const command = new GetMatchingJobCommand(getJobInfoParams); const response = await erClient.send(command); console.log(`Job status: ${response.status}`); } catch (error) { console.log("error ", error.message); } } };
  • Consulte detalhes da API em GetMatchingJob na Referência de API do AWS SDK para JavaScript.

O código de exemplo a seguir mostra como usar GetSchemaMapping.

SDK para JavaScript (v3)
nota

Há mais no GitHub. Encontre o exemplo completo e veja como configurar e executar no AWS Code Examples Repository.

//The default inputs for this demo are read from the ../inputs.json. import { fileURLToPath } from "node:url"; import { GetSchemaMappingCommand, EntityResolutionClient, } from "@aws-sdk/client-entityresolution"; import data from "../inputs.json" with { type: "json" }; const region = "eu-west-1"; const erClient = new EntityResolutionClient({ region: region }); export const main = async () => { const getSchemaMappingJsonParams = { schemaName: `${data.inputs.schemaNameJson}`, }; try { const command = new GetSchemaMappingCommand(getSchemaMappingJsonParams); const response = await erClient.send(command); console.log(response); console.log( `Schema mapping for the JSON data:\n ${response.mappedInputFields[0]}`, ); console.log("Schema mapping ARN is: ", response.schemaArn); } catch (caught) { console.error(caught.message); throw caught; } };
  • Consulte detalhes da API em GetSchemaMapping na Referência de API do AWS SDK para JavaScript.

O código de exemplo a seguir mostra como usar ListSchemaMappings.

SDK para JavaScript (v3)
nota

Há mais no GitHub. Encontre o exemplo completo e veja como configurar e executar no AWS Code Examples Repository.

//The default inputs for this demo are read from the ../inputs.json. import { fileURLToPath } from "node:url"; import { ListSchemaMappingsCommand, EntityResolutionClient, } from "@aws-sdk/client-entityresolution"; import data from "../inputs.json" with { type: "json" }; const region = "eu-west-1"; const erClient = new EntityResolutionClient({ region: region }); export const main = async () => { async function getInfo() { const listSchemaMappingsParams = { workflowName: `${data.inputs.workflowName}`, jobId: `${data.inputs.jobId}`, }; try { const command = new ListSchemaMappingsCommand(listSchemaMappingsParams); const response = await erClient.send(command); const noOfSchemas = response.schemaList.length; for (let i = 0; i < noOfSchemas; i++) { console.log( `Schema Mapping Name: ${response.schemaList[i].schemaName} `, ); } } catch (caught) { console.error(caught.message); throw caught; } }
  • Consulte detalhes da API em ListSchemaMappings na Referência de API do AWS SDK para JavaScript.

O código de exemplo a seguir mostra como usar StartMatchingJob.

SDK para JavaScript (v3)
nota

Há mais no GitHub. Encontre o exemplo completo e veja como configurar e executar no AWS Code Examples Repository.

//The default inputs for this demo are read from the ../inputs.json. import { fileURLToPath } from "node:url"; import { StartMatchingJobCommand, EntityResolutionClient, } from "@aws-sdk/client-entityresolution"; import data from "../inputs.json" with { type: "json" }; const region = "eu-west-1"; const erClient = new EntityResolutionClient({ region: region }); export const main = async () => { const matchingJobOfWorkflowParams = { workflowName: `${data.inputs.workflowName}`, }; try { const command = new StartMatchingJobCommand(matchingJobOfWorkflowParams); const response = await erClient.send(command); console.log(`Job ID: ${response.jobID} \n The matching job was successfully started.`); } catch (caught) { console.error(caught.message); throw caught; } };
  • Consulte detalhes da API em StartMatchingJob na Referência de API do AWS SDK para JavaScript.

O código de exemplo a seguir mostra como usar TagResource.

SDK para JavaScript (v3)
nota

Há mais no GitHub. Encontre o exemplo completo e veja como configurar e executar no AWS Code Examples Repository.

//The default inputs for this demo are read from the ../inputs.json. import { fileURLToPath } from "node:url"; import { TagResourceCommand, EntityResolutionClient, } from "@aws-sdk/client-entityresolution"; import data from "../inputs.json" with { type: "json" }; const region = "eu-west-1"; const erClient = new EntityResolutionClient({ region: region }); export const main = async () => { const tagResourceCommandParams = { resourceArn: `${data.inputs.schemaArn}`, tags: { tag1: "tag1Value", tag2: "tag2Value", }, }; try { const command = new TagResourceCommand(tagResourceCommandParams); const response = await erClient.send(command); console.log("Successfully tagged the resource."); } catch (caught) { console.error(caught.message); throw caught; } };
  • Consulte detalhes da API em TagResource na Referência da API AWS SDK para JavaScript.