기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

Amazon Location Service용 Amazon Aurora PostgreSQL 사용자 정의 함수

Amazon Location Service를 사용하면 데이터베이스 테이블에 저장된 좌표와 주소를 사용하여 지리 공간 데이터를 정리하고 강화할 수 있습니다.

예:

이 튜토리얼에서는 Amazon Location Service를 사용하여 Amazon Aurora PostgreSQL 데이터베이스 테이블에 저장된 주소를 포맷하고 강화하는 방법을 보여줍니다.

샘플 코드는 AWS CloudFormation템플릿이 포함된 Amazon Location Service 샘플 리포지토리에서 사용할 수 있습니다. GitHub

개요

아키텍처에는 다음과 같은 통합이 포함됩니다.

사전 조건

시작하려면 다음 사전 요구 사항이 필요합니다.

빠른 시작

이 튜토리얼의 단계를 수행하는 대신 빠른 스택을 실행하여 Amazon Location 작업 SearchPlaceIndexForText을 지원하는 AWS Lambda 함수를 배포할 수 있습니다. 그러면 Amazon Aurora가 AWS Lambda를 호출할 수 있도록 AWS 계정이 자동으로 구성됩니다.

AWS 계정을 구성한 후에는 다음을 수행해야 합니다.

장소 색인 리소스 만들기

먼저 지오코딩 쿼리를 지원하는 장소 색인 리소스를 만드는 것부터 시작합니다.

지오코딩을 위한 AWS Lambda 함수 생성

Amazon Aurora PostgreSQL과 Amazon Location Service 간에 연결을 생성하려면 데이터베이스 엔진의 요청을 처리하는 AWS Lambda 함수가 필요합니다. 이 함수는 Lambda 사용자 정의 함수 이벤트를 변환하고 Amazon Location 작업 SearchPlaceIndexForText을 호출합니다.

AWS Lambda 콘솔, AWS Command Line Interface 또는 AWS Lambda API를 사용하여 함수를 생성할 수 있습니다.

콘솔을 사용하여 Lambda 사용자 정의 함수를 생성하려면

Amazon Aurora PostgreSQL 액세스 권한을 AWS Lambda에 부여

Amazon Aurora PostgreSQL이 AWS Lambda 함수를 호출하려면 먼저 액세스 권한을 부여해야 합니다.

Amazon Aurora PostgreSQL 클러스터에 공개적으로 액세스할 수 없는 경우, Amazon Aurora가 Lambda 함수를 호출하도록 하려면 먼저 AWS Lambda에 대한 VPC 엔드포인트를 생성해야 합니다.

AWS Lambda에 대한 VPC 엔드포인트 생성

AWS Lambda 함수 호출 권한을 부여하는 IAM 정책을 생성합니다.

IAM 역할을 생성하여 Amazon Relational Database Service (RDS)에 권한을 부여하기

IAM 역할을 생성하면 Amazon Aurora PostgreSQL이 사용자 대신 Lambda 함수에 액세스하는 역할을 맡을 수 있습니다. 자세한 내용은 IAM 사용 설명서의 IAM 사용자에게 권한을 위임하기 위한 역할 생성을 참조하십시오.

다음 예제는 다음과 같은 역할을 생성하는 AWS CLI 명령입니다 AuroraGeocoderInvokeRole.

aws iam create-role  --role-name rds-lambda-role --assume-role-policy-document '{
    "Version": "2012-10-17",
    "Statement": [
        {
        "Effect": "Allow",
        "Principal": {
            "Service": "rds.amazonaws.com"
        },
        "Action": "sts:AssumeRole"
        }
    ] 
}'

IAM 정책을 IAM 역할에 연결합니다.

IAM 역할이 있는 경우 생성한 IAM 정책을 연결합니다.

다음 예제는 정책을 AuroraGeocoderInvoke역할에 AuroraGeocoderInvokeRole연결하는 AWS CLI 명령입니다.

aws iam attach-role-policy  --policy-arn AuroraGeocoderInvoke  --role-name AuroraGeocoderInvokeRole

IAM 역할을 Amazon Aurora DB 클러스터에 추가

다음 예제는 라는 Amazon Aurora PostgreSQL DB 클러스터에 IAM 역할을 추가하는 AWS CLI 명령입니다. MyAuroraCluster

aws rds add-role-to-db-cluster \
--db-cluster-identifier MyAuroraCluster \
--feature-name Lambda \
--role-arn AuroraGeocoderInvokeRole   \
--region your-region

AWS Lambda 함수 호출

지오코딩 Lambda 함수를 호출할 권한을 Amazon Aurora PostgreSQL에 부여한 후에는 지오코딩 AWS Lambda 함수를 호출하는 Amazon Aurora PostgreSQL 사용자 정의 함수를 생성할 수 있습니다. 자세한 내용은 Amazon Aurora 사용 설명서의 Amazon Aurora PostgreSQL DB 클러스터에서 AWS Lambda 함수 호출을 참조하십시오.

필요한 PostgreSQL 확장을 설치합니다.

필수 PostgreSQL 확장 aws_lambda 및 aws _commons 확장을 설치하려면 Amazon Aurora 사용 설명서의 Lambda 함수 사용에 대한 개요를 참조하세요.

CREATE EXTENSION IF NOT EXISTS aws_lambda CASCADE;

필요한 PostGIS 확장을 설치합니다.

PostGIS는 공간 정보를 저장하고 관리하기 위해 PostgreSQL을 확장한 것입니다. 자세한 내용은 Amazon 관계형 데이터베이스 서비스 사용 설명서의 PostGIS 확장 작업을 참조하세요.

CREATE EXTENSION IF NOT EXISTS postgis;

Lambda 함수를 호출하는 SQL 사용자 정의 함수 생성

SQL 편집기에서 새 사용자 정의 함수를 f_SearchPlaceIndexForText 생성하여 함수를 호출합니다. AuroraGeocoder

CREATE OR REPLACE FUNCTION f_SearchPlaceIndexForText(
  text text,
  bias_position geometry(Point, 4326) DEFAULT NULL,
  filter_bbox box2d DEFAULT NULL,
  filter_countries text[] DEFAULT NULL,
  max_results int DEFAULT 1
)
 RETURNS TABLE (
   label text,
   address_number text,
   street text,
   municipality text,
   postal_code text,
   sub_region text,
   region text,
   country text,
   geom geometry(Point, 4326)
 )
 LANGUAGE plpgsql
 IMMUTABLE
AS $function$
begin
    RETURN QUERY
    WITH results AS (
      SELECT json_array_elements(payload) rsp
      FROM aws_lambda.invoke(
        aws_commons.create_lambda_function_arn('AuroraGeocoder'),
        json_build_object(
          'text', text,
          'biasPosition',
          CASE WHEN bias_position IS NOT NULL THEN
            array_to_json(ARRAY[ST_X(bias_position), ST_Y(bias_position)])
          END,
          'filterBBox',
          CASE WHEN filter_bbox IS NOT NULL THEN
            array_to_json(ARRAY[ST_XMin(filter_bbox), ST_YMin(filter_bbox), ST_XMax(filter_bbox), ST_YMax(filter_bbox)])
          END,
          'filterCountries', filter_countries,
          'maxResults', max_results
        )
      )
    )
    SELECT
      rsp->'Place'->>'Label' AS label,
      rsp->'Place'->>'AddressNumber' AS address_number,
      rsp->'Place'->>'Street' AS street,
      rsp->'Place'->>'Municipality' AS municipality,
      rsp->'Place'->>'PostalCode' AS postal_code,
      rsp->'Place'->>'SubRegion' AS sub_region,
      rsp->'Place'->>'Region' AS region,
      rsp->'Place'->>'Country' AS country,
      ST_GeomFromGeoJSON(
        json_build_object(
          'type', 'Point',
            'coordinates', rsp->'Place'->'Geometry'->'Point'
        )
      ) geom
    FROM results;
end;
$function$;

SQL 함수를 호출하여 Aurora에서 지오코딩하기

SQL 문을 실행하면 Lambda AuroraGeocoder함수가 호출됩니다. 이 함수는 데이터베이스의 데이터베이스 테이블에서 주소 레코드를 가져와 장소 인덱스 Amazon Aurora PostgreSQL 리소스를 사용하여 지오코딩합니다.

다음 f_SearchPlaceIndexForText SQL 함수는 AuroraGeocoderLambda 함수를 통해 아마존 로케이션의 SearchPlaceIndexForText API에 요청을 보냅니다. 이 함수는 ST_AsText(geom)가 텍스트로 변환되는 PostGIS 지오메트리인 geom 열을 반환합니다.

SELECT *, ST_AsText(geom)
FROM f_SearchPlaceIndexForText('Vancouver, BC');

기본적으로 반환에는 하나의 행이 포함됩니다. MaxResults 한도까지 추가 행을 요청하려면 BiasPosition을 제공하고 결과를 캐나다로 제한하면서 다음 SQL 문을 실행하세요.

SELECT *
FROM f_SearchPlaceIndexForText('Mount Pleasant', ST_MakePoint(-123.113, 49.260), null, '{"CAN"}', 5);

경계 상자를 사용하여 결과를 필터링하려면 Box2D를 filter_bbox로 전달합니다.

SELECT *
FROM f_SearchPlaceIndexForText('Mount Pleasant', null, 'BOX(-139.06 48.30, -114.03 60.00)'::box2d, '{"CAN"}', 5);

PostGIS 유형과 함수에 대한 자세한 내용은 PostGIS 참조를 참조하세요.

주소 데이터를 포함하는 데이터베이스 강화

다음 데이터가 다음 열로 구분된 데이터베이스 테이블이 주어지면 Amazon Location 작업 SearchPlaceIndexForText을 사용하여 형식화된 주소를 생성하는 동시에 정규화 및 지오코딩 수행할 수 있습니다.

WITH source_data AS (
  SELECT
    id,
    address || ', ' || city || ', ' || state || ', ' || zip AS formatted_address
  FROM addresses
),
geocoded_data AS (
  SELECT
    *,
    (f_SearchPlaceIndexForText(formatted_address)).*
  FROM source_data
)
SELECT
  id,
  formatted_address,
  label normalized_address,
  ST_Y(geom) latitude,
  ST_X(geom) longitude
FROM geocoded_data
-- limit the number of rows that will be geocoded; remove this to geocode the entire table
LIMIT 1;

다음 예시는 결과 데이터테이블 행 하나를 보여줍니다.

 id |      formatted_address         |            normalized_address              |     latitude     |     longitude
----+--------------------------------+--------------------------------------------+------------------+-------------------
 42 | 123 Anytown Ave N, Seattle, WA | 123 Anytown Ave N, Seattle, WA, 12345, USA | 47.6223000127926 | -122.336745971039
(1 row)

데이터베이스 테이블 업데이트 및 열 채우기

다음 예시에서는 테이블을 업데이트하고 SearchPlaceIndexForText 쿼리의 결과로 열을 채웁니다.

WITH source_data AS (
  -- select rows that have not been geocoded and created a formatted address for each
  SELECT
    id,
    address || ', ' || city || ', ' || state || ', ' || zip AS formatted_address
  FROM addresses
  WHERE label IS NULL
  -- limit the number of rows that will be geocoded; remove this to geocode the entire table
  LIMIT 1
),
geocoded_data AS (
  -- geocode each row and keep it linked to the source's ID
  SELECT
    id,
    (f_SearchPlaceIndexForText(formatted_address)).*
  FROM source_data
)
UPDATE addresses
-- populate columns
SET
  normalized_address = geocoded_data.label,
  latitude = ST_Y(geocoded_data.geom),
  longitude = ST_X(geocoded_data.geom)
FROM geocoded_data
-- ensure that rows match
WHERE addresses.id = geocoded_data.id;

다음 단계

샘플 코드는 AWS CloudFormation템플릿이 포함된 Amazon Location Service 샘플 리포지토리에서 사용할 수 있습니다. GitHub