Не удалось прочитать ответ json body от aws lambda (java). Это говорит ReadableStream - PullRequest
0 голосов
/ 30 октября 2019

У меня есть безсерверная система, где мой бэкэнд находится в AWS лямбда (java), а внешний интерфейс - в реакции. Я отправляю введенное пользователем значение имени и ожидаю привет {имя} в ответ. Я использую fetch api (post) для отправки введенных пользователем данных, в данном случае «name», на серверную лямбду. Лямбда может распечатать и изменить его. Он отправляет ответ jsonnode обратно во внешний интерфейс, но на внешнем интерфейсе, когда я console.log (response) не печатает ничего в теле.

Он говорит тело: {...} и при нажатии на три точки он говорит Object ReadableStream. body: ReadableStream заблокирован: false

Я вижу обновленное значение в -> Network-> Response. (при устранении неполадок с помощью chrome dev tools). Как я могу получить доступ к этому значению и использовать его на внешнем интерфейсе?

Код внутреннего кода:

public class DataProcessor {

    LambdaLogger logger;
    ObjectMapper objectMapper;

    public void handler(InputStream inputStream, OutputStream outputStream, Context context) throws IOException {

        this.logger = context.getLogger();
        this.objectMapper = new ObjectMapper();
        logger.log("Beginning data processing");

        // Get our inputs
        JsonNode body = this.extractBody(inputStream);

        logger.log(body.toString());

        String username = body.get("headers").get("X-FORWARDED-USER").toString().replace("\"", "");
        String method = body.get("httpMethod").toString().replace("\"", "");
        String path = body.get("path").toString().replace("\"", "");
        String data = body.get("body").toString().replace("\"", "");
        Boolean isBase64Encoded = body.get("isBase64Encoded").asBoolean();

        if (isBase64Encoded) {
          data = new String(Base64.getDecoder().decode(data), "utf-8");
        }

        logger.log("username: " + username);
        logger.log("method: " + method);
        logger.log("path: " + path);
        logger.log("data: " + data);
        logger.log("isBase64Encoded: " + isBase64Encoded);

        JsonNode responseJson;

        responseJson =  (JsonNode)constructResponse(data);

        logger.log("Response: " + responseJson.toString());

        // Output the response
        OutputStreamWriter writer = new OutputStreamWriter(outputStream, "UTF-8");
        writer.write(responseJson.toString());
        writer.close();
    }

    // construct response
    private ObjectNode constructResponse(String body) throws IOException {
      ObjectNode response = this.objectMapper.createObjectNode();
      response.put("statusCode", 200);
      response.put("isBase64Encoded", true);
      response.put("body", body);
      response.put("headers", this.objectMapper.readTree("{\"Content-Type\":\"application/json\"}"));
      return response;
    }

    // get body from inputStream
    private JsonNode extractBody(InputStream inputStream) throws IOException {
        ObjectMapper objectMapper = new ObjectMapper();
        JsonNode input = objectMapper.readValue(inputStream, JsonNode.class);
        return input;
    }
}

Код пользовательского интерфейса внешнего интерфейса

class MyForm extends React.Component {
  constructor() {
    super();
    this.state={ name: ''};
    this.handleChange = this.handleChange.bind(this);
    this.handleClick = this.handleClick.bind(this);
  }

  handleChange = event =>{
    this.setState({ [event.target.name]:event.target.value })
  }

  handleClick = event =>{
    this.setState(state => ({
        isFormOn: !state.isFormOn,
        name: state.name
    }));
  }

  handleSubmit = event =>{
    event.preventDefault();
    console.log("Name : " + this.state.name)

    const url ="abc"

    const data = { name:this.state.name}

    console.log("Data is : ", data)

    fetch(url, {
        method: 'POST',
        body: JSON.stringify(data)
     })
     .then(function(response){
        console.log("Response is : ", response);
        let json = JSON.parse(response);
        console.log("This is json parsed string : ", JSON.stringify(json));
     })
     .then(data => console.log("data is : ", data))
     .catch(error => console.error('Error:', error))

  }

  render(){
    return(
        <div>
            {
                <form onSubmit={this.handleSubmit}>
                    Name : <input type="text" name="name" onChange={this.handleChange} />
                    <input type="submit" value="Submit" />
                </form>
            }
        </div>
    )
  }

}

ReactDOM.render(
  <MyForm />,
  document.getElementById('root')
);

1 Ответ

1 голос
/ 30 октября 2019

Вам нужно прочитать и проанализировать ответ, используя json () , который берет поток ответа и читает его до завершения:

 fetch(url, {
    method: 'POST',
    body: JSON.stringify(data)
 })
 .then(response => response.json())
 .then(data => console.log("data is : ", data))
 .catch(error => console.error('Error:', error))
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...