Как написать обработчик Java Lambda для веб-сокета API Gateway?

Вот ответ, который я получил от службы поддержки AWS. Оно работает! Однако я еще не смог отправить обратно клиенту. Если кто-то успешно это сделал, пожалуйста, дайте мне знать. Я пытаюсь использовать AmazonHTTPClient, и мне непонятно, как правильно подписать сообщение с помощью AWS4Signer. Если кто-то успешно сделал это, пожалуйста, дайте мне знать.

В настоящее время мы не предлагаем поддержку веб-сокетов в APIGatewayProxyRequestEvent, как в REST [1]. Однако я упомянул об этом команде, которая занимается репозиторием GitHub, так что в конечном итоге они также реализуют класс для веб-сокета.

Альтернативой на данный момент является обработка ввода как потока и его синтаксический анализ с использованием любого доступного синтаксического анализатора JSON. Для начала я приложил пример проекта, который вы можете собрать с помощью "mvn package" и загрузить в Lambda. Я протестировал его лично и смог распечатать весь requestContext [2], возвращаемый шлюзом API, в виде строки. Единственная отсутствующая часть — это синтаксический анализ строки JSON.

Обратите внимание, что код, который я предоставил, взят из некоторых примеров, которые я смог собрать внутри, и он не готов к производству, он предназначен исключительно для использования в качестве шаблонного кода. Также я хочу отметить, что поддержка кода обычно выходит за рамки AWS Premium Support, поэтому я не могу гарантировать, что я или другие инженеры AWS смогут поддерживать этот код в дальнейшем. Однако я хотел предоставить вам кое-что для начала, так как я понимаю, что в нашей документации отсутствуют примеры шлюза API веб-сокетов и Java.

ОБРАЗЕЦ КОДА

package example;

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestStreamHandler;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

public class LambdaBasicStreamFunction implements RequestStreamHandler {
    @Override
    public void handleRequest(InputStream inputStream, OutputStream outputStream, Context context) throws IOException {
        int letter;
        String eventObject = "";

        while ((letter = inputStream.read()) > -1) {
            char inputChar= (char) letter;
            eventObject += inputChar;
        }

        //Passing a custom response as the output string
        String response = "{\n" +
                "    \"statusCode\": 200,\n" +
                "    \"headers\": {\"Content-Type\": \"application/json\"},\n" +
                "    \"body\": \"plain text response\"\n" +
                "}";
        outputStream.write(response.getBytes());

        System.out.println("Input-Event: " + eventObject);
    }
}