Java 함수를 Azure Storage에 연결
Azure Functions를 사용하면 자체 통합 코드를 작성하지 않고도 함수에 Azure 서비스 및 기타 리소스를 연결할 수 있습니다. 입력과 출력을 모두 나타내는 이러한 바인딩은 함수 정의 내에서 선언됩니다. 바인딩의 데이터는 함수에 매개 변수로 제공됩니다. 트리거는 특수한 형식의 입력 바인딩입니다. 함수에는 하나의 트리거만 있지만, 여러 개의 입력 및 출력 바인딩이 있을 수 있습니다. 자세한 내용은 Azure Functions 트리거 및 바인딩 개념을 참조하세요.
이전의 빠른 시작 문서에서 Azure Storage 큐를 사용하여 만든 함수를 통합하는 방법을 보여줍니다. 이 함수에 추가하는 출력 바인딩은 HTTP 요청의 데이터를 큐의 메시지에 씁니다.
대부분의 바인딩은 Functions에서 바인딩된 서비스에 액세스할 때 사용할 저장된 연결 문자열이 필요합니다. 이 연결을 더 쉽게 만들려면 함수 앱에서 만든 Storage 계정을 사용합니다. 이 계정에 대한 연결은 이미 AzureWebJobsStorage 앱 설정에 저장되어 있습니다.
필수 조건
이 문서를 시작하기에 앞서 Java 빠른 시작의 1부 단계를 먼저 완료합니다.
함수 앱 설정 다운로드
이미 Azure에서 필요한 Storage 계정과 함께 함수 앱을 만들었습니다. 이 계정의 연결 문자열은 Azure의 앱 설정에 안전하게 저장됩니다. 이 문서에서는 같은 계정의 Storage 큐에 메시지를 작성합니다. 함수를 로컬로 실행할 때 Storage 계정에 연결하려면 앱 설정을 local.settings.json 파일에 다운로드해야 합니다.
프로젝트의 루트에서 다음 Azure Functions Core Tools 명령을 실행하여 설정을 local.settings.json에 다운로드하고, <APP_NAME>을 이전 문서의 함수 앱 이름으로 바꿉니다.
func azure functionapp fetch-app-settings <APP_NAME>
Azure 계정에 로그인해야 할 수도 있습니다.
Important
이 명령은 기존 설정을 Azure의 함수 앱 값으로 덮어씁니다.
local.settings.json 파일은 비밀을 포함하고 있으므로 절대 게시되지 않으며, 소스 제어에서 제외되어야 합니다.
Storage 계정 연결 문자열인 AzureWebJobsStorage 값이 필요합니다. 이 연결을 사용하여 출력 바인딩이 예상대로 작동하는지 확인합니다.
확장 번들 사용
바인딩 확장을 설치하는 가장 쉬운 방법은 확장 번들을 사용하도록 설정하는 것입니다. 번들을 활성화하면 미리 정의된 확장 패키지 세트가 자동으로 설치됩니다.
확장 번들을 사용하도록 설정하려면 host.json 파일을 열고 다음 코드와 일치하도록 콘텐츠를 업데이트합니다.
{
"version": "2.0",
"extensionBundle": {
"id": "Microsoft.Azure.Functions.ExtensionBundle",
"version": "[3.*, 4.0.0)"
}
}
이제 Storage 출력 바인딩을 프로젝트에 추가할 수 있습니다.
출력 바인딩 추가
Java 프로젝트에서 바인딩은 함수 메서드의 바인딩 주석으로 정의됩니다. 그런 다음, function.json 파일은 이러한 주석을 기반으로 자동으로 생성됩니다.
src/main/java에서 함수 코드의 위치로 이동하여 Function.java 프로젝트 파일을 열고, 다음 매개 변수를 run 메서드 정의에 추가합니다.
@QueueOutput(name = "msg", queueName = "outqueue", connection = "AzureWebJobsStorage") OutputBinding<String> msg
msg 매개 변수는 문자열 컬렉션을 나타내는 OutputBinding<T> 형식입니다. 이러한 문자열은 함수가 완료될 때 출력 바인딩에 메시지로 기록됩니다. 이 경우 출력은 outqueue라는 스토리지 큐입니다. 스토리지 계정에 대한 연결 문자열은 connection 메서드로 설정됩니다. 연결 문자열 자체를 전달하는 대신 스토리지 계정 연결 문자열이 포함된 애플리케이션 설정을 전달합니다.
이제 run 메서드 정의는 다음 예와 같아야 합니다.
@FunctionName("HttpTrigger-Java")
public HttpResponseMessage run(
@HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.FUNCTION)
HttpRequestMessage<Optional<String>> request,
@QueueOutput(name = "msg", queueName = "outqueue", connection = "AzureWebJobsStorage")
OutputBinding<String> msg, final ExecutionContext context) {
...
}
출력 바인딩을 사용하는 코드 추가
이제 새 msg 매개 변수를 사용하여 함수 코드에서 출력 바인딩에 쓸 수 있습니다. 성공 응답 앞에 다음 코드 줄을 추가하여 name 값을 msg 출력 바인딩에 추가합니다.
msg.setValue(name);
출력 바인딩을 사용하면 인증하거나, 큐 참조를 가져오거나, 데이터를 쓰는 데 Azure Storage SDK 코드를 사용할 필요가 없습니다. Functions 런타임 및 큐 출력 바인딩이 이러한 작업을 알아서 처리합니다.
이제 run 메서드가 다음 예와 같아야 합니다.
public HttpResponseMessage run(
@HttpTrigger(name = "req", methods = {HttpMethod.GET, HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS)
HttpRequestMessage<Optional<String>> request,
@QueueOutput(name = "msg", queueName = "outqueue",
connection = "AzureWebJobsStorage") OutputBinding<String> msg,
final ExecutionContext context) {
context.getLogger().info("Java HTTP trigger processed a request.");
// Parse query parameter
String query = request.getQueryParameters().get("name");
String name = request.getBody().orElse(query);
if (name == null) {
return request.createResponseBuilder(HttpStatus.BAD_REQUEST)
.body("Please pass a name on the query string or in the request body").build();
} else {
// Write the name to the message queue.
msg.setValue(name);
return request.createResponseBuilder(HttpStatus.OK).body("Hello, " + name).build();
}
}
테스트 업데이트
또한 원형은 테스트 세트를 만들기 때문에 run 메서드 시그니처에서 새 msg 매개 변수를 처리하도록 이러한 테스트를 업데이트해야 합니다.
src/test/java에서 테스트 코드의 위치로 이동하여 Function.java 프로젝트 파일을 열고, //Invoke 아래의 코드 줄을 다음 코드로 바꿉니다.
@SuppressWarnings("unchecked")
final OutputBinding<String> msg = (OutputBinding<String>)mock(OutputBinding.class);
final HttpResponseMessage ret = new Function().run(req, msg, context);
이제 새 출력 바인딩을 로컬로 사용해 볼 준비가 되었습니다.
로컬에서 함수 실행
이전과 마찬가지로 다음 명령을 사용하여 프로젝트를 빌드하고 로컬로 Functions 런타임을 시작합니다.
참고 항목
host.json에서 확장 번들을 사용하도록 설정했으므로 시작 시 Storage 바인딩 확장이 다른 Microsoft 바인딩 확장과 함께 자동으로 다운로드되어 설치되었습니다.
이전과 마찬가지로 새 터미널 창에서 cURL을 사용하여 명령줄에서 함수를 트리거합니다.
curl -w "\n" http://localhost:7071/api/HttpTrigger-Java --data AzureFunctions
이번에는 출력 바인딩이 Storage 계정에 outqueue라는 큐를 만들고 똑같은 이 문자열을 사용하여 메시지를 추가합니다.
다음으로, Azure CLI를 사용하여 새 큐를 살펴보고 메시지가 추가되었는 확인합니다. 큐는 Microsoft Azure Storage Explorer 또는 Azure Portal을 사용하여 확인할 수도 있습니다.
Storage 계정 연결 설정
local.settings.json 파일을 열고, Storage 계정 연결 문자열인 AzureWebJobsStorage 값을 복사합니다. 다음 Bash 명령을 사용하여 AZURE_STORAGE_CONNECTION_STRING 환경 변수를 연결 문자열로 설정합니다.
AZURE_STORAGE_CONNECTION_STRING="<STORAGE_CONNECTION_STRING>"
연결 문자열이 AZURE_STORAGE_CONNECTION_STRING 환경 변수에 설정되면 매번 인증하지 않고도 Storage 계정에 액세스할 수 있습니다.
Storage 큐 쿼리
다음 예제처럼 az storage queue list 명령을 사용하여 계정의 Storage 큐를 볼 수 있습니다.
az storage queue list --output tsv
이 명령의 출력에는 함수가 실행될 때 생성된 outqueue라는 큐가 포함됩니다.
다음으로, 다음 예제와 같이 az storage message peek 명령을 사용하여 이 큐의 메시지를 확인합니다.
echo `echo $(az storage message peek --queue-name outqueue -o tsv --query '[].{Message:content}') | base64 --decode`
반환된 문자열은 함수를 테스트하기 위해 보낸 메시지와 동일해야 합니다.
참고 항목
이전 예제는 base64에서 반환된 문자열을 디코딩합니다. Queue 스토리지 바인딩이 Azure Storage에 base64 문자열로 쓰고 읽기 때문입니다.
프로젝트 다시 배포
게시된 앱을 업데이트하려면 다음 명령을 다시 실행합니다.
마찬가지로 cURL을 사용하여 배포된 함수를 테스트할 수 있습니다. 이전과 마찬가지로 다음 예제와 같이 POST 요청의 본문에 있는 AzureFunctions 값을 URL에 전달합니다.
curl -w "\n" https://fabrikam-functions-20190929094703749.azurewebsites.net/api/HttpTrigger-Java?code=zYRohsTwBlZ68YF.... --data AzureFunctions
Storage 큐 메시지를 검사하여 출력 바인딩이 예상대로 큐에 새 메시지를 생성하는지 다시 확인할 수 있습니다.
리소스 정리
이 컬렉션의 다른 빠른 시작은 이 빠른 시작을 기반으로 구성됩니다. 이후의 빠른 시작 또는 자습서를 사용하여 계속하려는 경우 이 빠른 시작에서 만든 리소스를 정리하지 마세요. 계속하지 않으려는 경우 다음 명령을 사용하여 이 빠른 시작에서 만든 모든 리소스를 삭제합니다.
az group delete --name myResourceGroup
메시지가 표시되면 y를 선택합니다.
다음 단계
데이터를 Storage 큐에 쓰도록 HTTP 트리거 함수를 업데이트했습니다. Java를 사용하여 Azure Functions를 개발하는 방법에 대한 자세한 내용은 Azure Functions Java 개발자 가이드 및 Azure Functions 트리거 및 바인딩을 참조하세요. Java의 전체 함수 프로젝트 예제는 Java Functions 샘플을 참조하세요.
다음으로, 함수 앱에 Application Insights 모니터링을 사용하도록 설정해야 합니다.