AWS Managed Flink 런타임 속성 업데이트 하는 방법(with. AWS CLI)

Background

• AWS Managed Flink 특정 App 에서 런타임 속성을 20개 정도 사용 중이다.
• 해당 서비스를 사용한 지 얼마 되지 않아 App 을 여러번 없애고 올리기를 반복 했다.
• 그러면서 여러번 런타임 속성을 콘솔 화면에서 하나씩 하다보니 너무 불편했다.
• 그래서 찾아보니 aws cli 를 이용해서 런타임 속성 업데이트가 가능하여 기록 하기로 한다.

UpdateApplication API 사용하기

[ 참고 문서 ]

• https://docs.aws.amazon.com/managed-flink/latest/java/how-properties.html
• https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html

$ aws kinesisanalyticsv2 update-application \
    --application-name {플링크-앱-이름} \
    --current-application-version-id {플링크-앱-버전ID} \
    --application-configuration-update '{
    "EnvironmentPropertyUpdates":
    {
        "PropertyGroups":
        [
            {
                "PropertyGroupId": "my-property-group-id-1",
                "PropertyMap":
                {
                    "key1": "value1",
                    "key2": "value2"
                }
            },
            {
                "PropertyGroupId": "my-property-group-id-2",
                "PropertyMap":
                {
                    "key1": "value1",
                    "key2": "value2"
                }
            }
        ]
    }
}'

📌 단, PropertyGroupId 값이 kinesis.analytics.flink.run.options 인 런타임 속성을 API 업데이트 하려면, Flink 소스 코드 zip 경로 등을 함께 바꿔야 한다.