示例代码:
const AWS = require('aws-sdk');
const http = require('http');
const es = new AWS.ES({
apiVersion: '2015-01-01',
region: 'us-west-2',
accessKeyId: 'your-access-key-id',
secretAccessKey: 'your-secret-access-key',
credentials: new AWS.Credentials({
accessKeyId: 'your-access-key-id',
secretAccessKey: 'your-secret-access-key'
})
});
const postData = JSON.stringify({
'key': 'value'
});
const options = {
host: 'search--.us-west-2.es.amazonaws.com',
path: '/myindex/mytype',
method: 'POST',
headers: {
'Content-Type': 'application/json',
'Content-Length': Buffer.byteLength(postData)
}
};
const req = http.request(options, (res) => {
console.log(`STATUS: ${res.statusCode}`);
console.log(`HEADERS: ${JSON.stringify(res.headers)}`);
res.setEncoding('utf8');
res.on('data', (chunk) => {
console.log(`BODY: ${chunk}`);
});
res.on('end', () => {
console.log('No more data in response.');
});
});
req.on('error', (e) => {
console.error(`problem with request: ${e.message}`);
});
req.write(postData);
req.end();