in lambda/streamConsumer/streamConsumer.js [78:93]
async function pushDataToClient(connectionId, endpointURL, feed) {
try {
const apigwManagementApi = new AWS.ApiGatewayManagementApi({
apiVersion: "2018-11-29",
endpoint: endpointURL,
})
console.log("pushToConnection : " + connectionId + " feed : " + JSON.stringify(feed))
var testfeed="Test feed"
var resp = await apigwManagementApi
.postToConnection({ ConnectionId: connectionId, Data: JSON.stringify(feed) })
.promise()
return resp;
} catch (err) {
return err;
}
}