Go 함수 패키징하기

현재 Go 함수는 SDK를 통해서만 구현할 수 있고, 함수의 인터페이스가 SDK 형태로 노출되어 있어요. Go 함수를 사용하기 전에 github.com/apache/pulsar/pulsar-function-go/pf를 임포트해야 해요.

Go 함수를 패키징하는 과정은 함수 파일 준비 → 빌드 → 실행 순서로 이어져요. 예제 명령을 따라가면 로컬에서 Go 함수를 바로 실행해 볼 수 있어요.

출처: 문서

본문

Go 함수를 패키징하려면 다음 단계를 완료해요.

Go 함수 파일을 준비해요.
Go 함수를 빌드해요.

 go build <your Go function filename>.go

다음 명령으로 Go 함수를 실행해요.

 bin/pulsar-admin functions localrun \
     --go [absolute path to your go function]
     --inputs [input topics] \
     --output [output topic] \
     --tenant [default:public] \
     --namespace [default:default] \
     --name [custom unique go function name]

다음 로그는 Go 함수가 성공적으로 시작되었음을 나타내요.

 ...
 07:55:03.724 [main] INFO  org.apache.pulsar.functions.runtime.ProcessRuntime - Started process successfully
 ...

더 알아보기 (Learn more)

함수 패키징의 전체 흐름이 궁금하다면 함수 패키징 문서를 참고해요.
클러스터 모드로 함수를 배포하는 방법은 함수 배포 문서를 살펴보세요.
Go SDK로 함수를 개발하는 방법은 함수 개발 API 문서에서 확인할 수 있어요.