为什么我在这里遇到了无法处理的承诺错误

Question

我正在尝试获取API数据，然后一旦收到该API数据，我希望通过将其保存到MongoDB，从而将其存储在后端。我正在使用节点和表示来完成这个任务。这是我目前遇到的错误：

(node:9072) UnhandledPromiseRejectionWarning: Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client
    at ServerResponse.setHeader (_http_outgoing.js:561:11)
    at ServerResponse.header (C:\Users\simer\Downloads\Talkhappi\server\node_modules\express\lib\response.js:794:10)
    at ServerResponse.send (C:\Users\simer\Downloads\Talkhappi\server\node_modules\express\lib\response.js:174:12)
    at ServerResponse.json (C:\Users\simer\Downloads\Talkhappi\server\node_modules\express\lib\response.js:278:15)
    at createUserData (C:\Users\simer\Downloads\Talkhappi\server\controllers\userDataController.js:93:28)
    at processTicksAndRejections (internal/process/task_queues.js:95:5)
(Use `node --trace-warnings ...` to show where the warning was created)
(node:9072) UnhandledPromiseRejectionWarning: Unhandled promise rejection. This error originated either 
by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). To terminate the node process on unhandled promise rejection, use the CLI flag `--unhandled-rejections=strict` (see https://nodejs.org/api/cli.html#cli_unhandled_rejections_mode). (rejection id: 1)
(node:9072) [DEP0018] DeprecationWarning: Unhandled promise rejections are deprecated. In the future, promise rejections that are not handled will terminate the Node.js process with a non-zero exit code.   

这是我的密码：

const { Configuration, OpenAIApi } = require("openai");
// create new user data
const createUserData = async (req, res) => {
    const {id, scores, transcript} = req.body
    const user_id = req.user._id

    const configuration = new Configuration({
        apiKey: process.env.OPENAI_API_KEY,
    });
    const openai = new OpenAIApi(configuration);

    // feedback
    const response = await openai.createCompletion({
        model: "text-davinci-002",
        prompt: "Provide personal feedback for me and give me tips: " + transcript,
        temperature: 1,
        max_tokens: 200,
        top_p: 1,
        frequency_penalty: 0,
        presence_penalty: 0,
    });

    // score
    const response2 = await openai.createCompletion({
        model: "text-davinci-002",
        prompt: "Give this text a number from 1-100 in terms of positivity: " + transcript,
        temperature: 1,
        max_tokens: 100,
        top_p: 1,
        frequency_penalty: 0,
        presence_penalty: 0,
    });

    // console.log(response.data.choices[0].text)
    // console.log(response2.data.choices)

    const newUserData = new UserData({
        id: 'user',
        scores: response2.data.choices[0].text,
        transcript: transcript,
        user_id: user_id,
        feedback: response.data.choices[0].text
    })

    console.log(newUserData)
    // add doc to db
    try {
        await newUserData.save()
    } catch (error) {
        res.status(400).json({error: error.message})
    }

    console.log('POST:', newUserData)
    return res.status(201).json({user_data: newUserData, feedback: response.data.choices[0].text, score: response2.data.choices[0].text})
}

我如何正确地编写这个异步代码来正确地完成我想要做的事情？

Answer 1

该错误的可能根源是，当代码执行时：

res.status(400).json({error: error.message})

然后，它通过并执行：

return res.status(201).json({user_data: newUserData, feedback: response.data.choices[0].text, score: response2.data.choices[0].text})

这将尝试向相同的传入请求发送两个响应，并给出ERR_HTTP_HEADERS_SENT错误。

您可以通过添加一个返回来解决这个问题：

res.status(400).json({error: error.message});
return;

这样代码就不会传递给其他res.send()了。

但是，这里还需要完成更多的错误处理，因为在这个函数中，您没有处理来自await语句的任何错误。

您可以捕获其他await语句中的错误，如下所示：

const { Configuration, OpenAIApi } = require("openai");
// create new user data
const createUserData = async (req, res) => {
    try {
        const { id, scores, transcript } = req.body
        const user_id = req.user._id

        const configuration = new Configuration({
            apiKey: process.env.OPENAI_API_KEY,
        });
        const openai = new OpenAIApi(configuration);

        // feedback
        const response = await openai.createCompletion({
            model: "text-davinci-002",
            prompt: "Provide personal feedback for me and give me tips: " + transcript,
            temperature: 1,
            max_tokens: 200,
            top_p: 1,
            frequency_penalty: 0,
            presence_penalty: 0,
        });

        // score
        const response2 = await openai.createCompletion({
            model: "text-davinci-002",
            prompt: "Give this text a number from 1-100 in terms of positivity: " + transcript,
            temperature: 1,
            max_tokens: 100,
            top_p: 1,
            frequency_penalty: 0,
            presence_penalty: 0,
        });

        // console.log(response.data.choices[0].text)
        // console.log(response2.data.choices)

        const newUserData = new UserData({
            id: 'user',
            scores: response2.data.choices[0].text,
            transcript: transcript,
            user_id: user_id,
            feedback: response.data.choices[0].text
        })

        console.log(newUserData)
        // add doc to db
        await newUserData.save();
        console.log('POST:', newUserData)
        res.status(201).json({ user_data: newUserData, feedback: response.data.choices[0].text, score: response2.data.choices[0].text })
    } catch (error) {
        console.log(error);
        res.status(400).json({ error: error.message })
    }
}