외부에 저장된 파일에 대한 배치 매핑 파일 생성

자세한 내용은 Salesforce 개발자 문서 및 권한 집합 만들기에서 통합 사용자를 참조하십시오.

OAuth 2.0 클라이언트 자격 증명 플로를 사용하는 로컬 외부 클라이언트 앱을 만듭니다. OAuth 설정에서 API를 통한 사용자 데이터 관리(api) 범위를 추가하고 Salesforce 통합 사용자를 다음으로 실행 사용자로 구성합니다.

자세한 지침은 외부 클라이언트 앱 만들기 및 클라이언트 자격 증명 플로 구성을 참조하십시오.

Salesforce에서 외부에 저장된 파일을 쿼리하고 각 Salesforce ContentDocument ID와 Amazon S3 위치 간 매핑을 생성하는 AWS 람다 함수를 배포합니다.

환경 변수를 통해 함수를 구성합니다. 지정된 S3 버킷에 매핑 파일을 작성하고 Amazon CloudWatch로 로그를 보내는 권한을 부여하는 s3:PutObject을 사용하여 IAM 실행 역할을 첨부합니다.

지침은 AWS 설명서의 Python 람다 함수 배포, 람다 환경 변수 사용, 람다 실행 역할을 참조하십시오.

다음은 참조 람다 코드입니다.

# 1. Authenticate to Salesforce (OAuth 2.0 Client Credentials)
token = sf_oauth_token(SF_INSTANCE_URL, SF_CLIENT_ID, SF_CLIENT_SECRET)

# 2. Query ContentVersion -> ContentDocumentId, ExternalDocumentInfo2, ExternalDataSource
soql = ("SELECT ContentDocumentId, ExternalDocumentInfo2, "
        "ExternalDataSource.NamedCredentialId, ExternalDataSource.MasterLabel "
        "FROM ContentVersion WHERE IsLatest=true AND ExternalDocumentInfo2!=null "
        "AND ExternalDataSource.Type='ContentHubAWSS3'")
records = sf_query_all(token, soql)

# 3. Resolve each Named Credential's S3 endpoint URL (Tooling API)
nc_url = {nc_id: sf_named_credential_url(token, nc_id)
          for nc_id in {r["ExternalDataSource"]["NamedCredentialId"] for r in records}}

# 4. Build the mapping keyed by the external document id
mapping = defaultdict(list)
for r in records:
    nc_id = r["ExternalDataSource"]["NamedCredentialId"]
    mapping[r["ExternalDocumentInfo2"]].append({
        "ContentDocumentId": r["ContentDocumentId"],
        "DataSourceLabel": r["ExternalDataSource"]["MasterLabel"],
        "NamedCredentialId": nc_id,
        "S3_Endpoint_URL": nc_url.get(nc_id),
    })

# 5. Upload the mapping JSON to S3
boto3.client("s3").put_object(
    Bucket=S3_BUCKET_NAME, Key=S3_FILE_NAME,
    Body=json.dumps(mapping, indent=4), ContentType="application/json")