首页 >> js开发 >> JavaScriptnodejs实现百度舆情接口应用示例
JavaScriptnodejs实现百度舆情接口应用示例
发布时间: 2021年1月13日 | 浏览:
| 分类:js开发
本文实例讲述了nodejs实现百度舆情接口。分享给大家供大家参考，具体如下：
const URL = require('url');
const http = require('http');
const https = require('https');
const qs = require('querystring');
let trends = exports;
trends.getInstance = function () {
return new Trends;
}
function Trends() {
this.expireTime = 1800;
this.accessKey = 'xxxxxxxx';
this.secretKey = 'xxxxxxxx';
this.userKey = 'xxxxxxxx';
this.userSecret = 'xxxxxxxx';
this.host = 'trends.baidubce.com';
this.timestamp = _.time();
this.utcTimestamp = _.utcTime();
}
Trends.prototype.request = async function (method, uri, params) {
method = method.toUpperCase();
let token = this.getToken();
let headers = this.getHeaders(method, uri);
params = Object.assign({}, params || {}, {
'user_key': this.userKey,
'token': token,
'timestamp': this.timestamp
});
let url = `http://${this.host}${uri}`;
return await this.httpRequest(method, url, params, headers);
}
Trends.prototype.getHeaders = function (method, uri) {
let authorization = this.getAuthorization(method, uri);
return {
'Content-Type': 'application/x-www-form-urlencoded',
'Host': this.host,
'x-bce-date': this.utcTimestamp,
'Authorization': authorization,
};
}
Trends.prototype.getAuthorization = function (method, uri) {
let authString = `bce-auth-v1/${this.accessKey}/${this.utcTimestamp}/${this.expireTime}`;
let signinKey = _.hmac(authString, this.secretKey, 'sha256');
let header = {
'host': this.host,
'x-bce-date': _.urlencode(this.utcTimestamp)
};
let headerArr = [];
for (let name in header) {
let val = header[name];
headerArr.push(`${name}:${val}`);
}
let headerKeyStr = Object.keys(header).sort().join(';');
let requestStr = `${method}\n${uri}\n\n${headerArr.join('\n')}`;
let signautre = _.hmac(requestStr, signinKey, 'sha256');
return `${authString}/${headerKeyStr}/${signautre}`;
}
Trends.prototype.getToken = function () {
return _.hmac(this.userKey + this.timestamp, this.userSecret);
}
Trends.prototype.httpRequest = async function (method, url, params, headers) {
let urlObj = URL.parse(url);
let protocol = urlObj.protocol;
let options = {
hostname: urlObj.hostname,
port: urlObj.port,
path: urlObj.path,
method: method,
headers: headers,
timeout: 10000,
};
let postData = qs.stringify(params || {});
return new Promise((resolve, reject) => {
let req = (protocol == 'http:' ? http : https).request(options, (res) => {
let chunks = [];
res.on('data', (data) => {
chunks.push(data);
});
res.on('end', () => {
let buffer = Buffer.concat(chunks);
let encoding = res.headers['content-encoding'];
if (encoding == 'gzip') {
zlib.unzip(buffer, function (err, decoded) {
resolve(decoded.toString());
});
} else if (encoding == 'deflate') {
zlib.inflate(buffer, function (err, decoded) {
resolve(decoded.toString());
});
} else {
resolve(buffer.toString());
}
});
});
req.on('error', (e) => {
_.error('request error', method, url, params, e);
resolve('');
});
req.on("timeout", (e) => {
_.error('request timeout', method, url, params, e);
resolve('');
})
if (method.toUpperCase() == 'POST') {
req.write(postData);
}
req.end();
});
}
const URL = require('url');
const http = require('http');
const https = require('https');
const qs = require('querystring');
let trends = exports;
trends.getInstance = function () {
return new Trends;
}
function Trends() {
this.expireTime = 1800;
this.accessKey = 'xxxxxxxx';
this.secretKey = 'xxxxxxxx';
this.userKey = 'xxxxxxxx';
this.userSecret = 'xxxxxxxx';
this.host = 'trends.baidubce.com';
this.timestamp = _.time();
this.utcTimestamp = _.utcTime();
}
Trends.prototype.request = async function (method, uri, params) {
method = method.toUpperCase();
let token = this.getToken();
let headers = this.getHeaders(method, uri);
params = Object.assign({}, params || {}, {
'user_key': this.userKey,
'token': token,
'timestamp': this.timestamp
});
let url = `http://${this.host}${uri}`;
return await this.httpRequest(method, url, params, headers);
}
Trends.prototype.getHeaders = function (method, uri) {
let authorization = this.getAuthorization(method, uri);
return {
'Content-Type': 'application/x-www-form-urlencoded',
'Host': this.host,
'x-bce-date': this.utcTimestamp,
'Authorization': authorization,
};
}
Trends.prototype.getAuthorization = function (method, uri) {
let authString = `bce-auth-v1/${this.accessKey}/${this.utcTimestamp}/${this.expireTime}`;
let signinKey = _.hmac(authString, this.secretKey, 'sha256');
let header = {
'host': this.host,
'x-bce-date': _.urlencode(this.utcTimestamp)
};
let headerArr = [];
for (let name in header) {
let val = header[name];
headerArr.push(`${name}:${val}`);
}
let headerKeyStr = Object.keys(header).sort().join(';');
let requestStr = `${method}\n${uri}\n\n${headerArr.join('\n')}`;
let signautre = _.hmac(requestStr, signinKey, 'sha256');
return `${authString}/${headerKeyStr}/${signautre}`;
}
Trends.prototype.getToken = function () {
return _.hmac(this.userKey + this.timestamp, this.userSecret);
}
Trends.prototype.httpRequest = async function (method, url, params, headers) {
let urlObj = URL.parse(url);
let protocol = urlObj.protocol;
let options = {
hostname: urlObj.hostname,
port: urlObj.port,
path: urlObj.path,
method: method,
headers: headers,
timeout: 10000,
};
let postData = qs.stringify(params || {});
return new Promise((resolve, reject) => {
let req = (protocol == 'http:' ? http : https).request(options, (res) => {
let chunks = [];
res.on('data', (data) => {
chunks.push(data);
});
res.on('end', () => {
let buffer = Buffer.concat(chunks);
let encoding = res.headers['content-encoding'];
if (encoding == 'gzip') {
zlib.unzip(buffer, function (err, decoded) {
resolve(decoded.toString());
});
} else if (encoding == 'deflate') {
zlib.inflate(buffer, function (err, decoded) {
resolve(decoded.toString());
});
} else {
resolve(buffer.toString());
}
});
});
req.on('error', (e) => {
_.error('request error', method, url, params, e);
resolve('');
});
req.on("timeout", (e) => {
_.error('request timeout', method, url, params, e);
resolve('');
})
if (method.toUpperCase() == 'POST') {
req.write(postData);
}
req.end();
});
}
module.exports = function () {
return new Script;
}
function Script() {}
Script.prototype.run = async function () {
let rst = this.getTaskList();
console.log(rst);
}
Script.prototype.getTaskList = async function () {
let params = {};
let method = 'post';
let uri = '/openapi/getTasklist';
let rst = await _.trends.getInstance().request(method, uri, params);
return rst;
}
module.exports = function () {
return new Script;
}
function Script() {}
Script.prototype.run = async function () {
let rst = this.getTaskList();
console.log(rst);
}
Script.prototype.getTaskList = async function () {
let params = {};
let method = 'post';
let uri = '/openapi/getTasklist';
let rst = await _.trends.getInstance().request(method, uri, params);
return rst;
}
希望本文所述对大家node.js程序设计有所帮助。
const URL = require('url');
const http = require('http');
const https = require('https');
const qs = require('querystring');
let trends = exports;
trends.getInstance = function () {
return new Trends;
}
function Trends() {
this.expireTime = 1800;
this.accessKey = 'xxxxxxxx';
this.secretKey = 'xxxxxxxx';
this.userKey = 'xxxxxxxx';
this.userSecret = 'xxxxxxxx';
this.host = 'trends.baidubce.com';
this.timestamp = _.time();
this.utcTimestamp = _.utcTime();
}
Trends.prototype.request = async function (method, uri, params) {
method = method.toUpperCase();
let token = this.getToken();
let headers = this.getHeaders(method, uri);
params = Object.assign({}, params || {}, {
'user_key': this.userKey,
'token': token,
'timestamp': this.timestamp
});
let url = `http://${this.host}${uri}`;
return await this.httpRequest(method, url, params, headers);
}
Trends.prototype.getHeaders = function (method, uri) {
let authorization = this.getAuthorization(method, uri);
return {
'Content-Type': 'application/x-www-form-urlencoded',
'Host': this.host,
'x-bce-date': this.utcTimestamp,
'Authorization': authorization,
};
}
Trends.prototype.getAuthorization = function (method, uri) {
let authString = `bce-auth-v1/${this.accessKey}/${this.utcTimestamp}/${this.expireTime}`;
let signinKey = _.hmac(authString, this.secretKey, 'sha256');
let header = {
'host': this.host,
'x-bce-date': _.urlencode(this.utcTimestamp)
};
let headerArr = [];
for (let name in header) {
let val = header[name];
headerArr.push(`${name}:${val}`);
}
let headerKeyStr = Object.keys(header).sort().join(';');
let requestStr = `${method}\n${uri}\n\n${headerArr.join('\n')}`;
let signautre = _.hmac(requestStr, signinKey, 'sha256');
return `${authString}/${headerKeyStr}/${signautre}`;
}
Trends.prototype.getToken = function () {
return _.hmac(this.userKey + this.timestamp, this.userSecret);
}
Trends.prototype.httpRequest = async function (method, url, params, headers) {
let urlObj = URL.parse(url);
let protocol = urlObj.protocol;
let options = {
hostname: urlObj.hostname,
port: urlObj.port,
path: urlObj.path,
method: method,
headers: headers,
timeout: 10000,
};
let postData = qs.stringify(params || {});
return new Promise((resolve, reject) => {
let req = (protocol == 'http:' ? http : https).request(options, (res) => {
let chunks = [];
res.on('data', (data) => {
chunks.push(data);
});
res.on('end', () => {
let buffer = Buffer.concat(chunks);
let encoding = res.headers['content-encoding'];
if (encoding == 'gzip') {
zlib.unzip(buffer, function (err, decoded) {
resolve(decoded.toString());
});
} else if (encoding == 'deflate') {
zlib.inflate(buffer, function (err, decoded) {
resolve(decoded.toString());
});
} else {
resolve(buffer.toString());
}
});
});
req.on('error', (e) => {
_.error('request error', method, url, params, e);
resolve('');
});
req.on("timeout", (e) => {
_.error('request timeout', method, url, params, e);
resolve('');
})
if (method.toUpperCase() == 'POST') {
req.write(postData);
}
req.end();
});
}
const URL = require('url');
const http = require('http');
const https = require('https');
const qs = require('querystring');
let trends = exports;
trends.getInstance = function () {
return new Trends;
}
function Trends() {
this.expireTime = 1800;
this.accessKey = 'xxxxxxxx';
this.secretKey = 'xxxxxxxx';
this.userKey = 'xxxxxxxx';
this.userSecret = 'xxxxxxxx';
this.host = 'trends.baidubce.com';
this.timestamp = _.time();
this.utcTimestamp = _.utcTime();
}
Trends.prototype.request = async function (method, uri, params) {
method = method.toUpperCase();
let token = this.getToken();
let headers = this.getHeaders(method, uri);
params = Object.assign({}, params || {}, {
'user_key': this.userKey,
'token': token,
'timestamp': this.timestamp
});
let url = `http://${this.host}${uri}`;
return await this.httpRequest(method, url, params, headers);
}
Trends.prototype.getHeaders = function (method, uri) {
let authorization = this.getAuthorization(method, uri);
return {
'Content-Type': 'application/x-www-form-urlencoded',
'Host': this.host,
'x-bce-date': this.utcTimestamp,
'Authorization': authorization,
};
}
Trends.prototype.getAuthorization = function (method, uri) {
let authString = `bce-auth-v1/${this.accessKey}/${this.utcTimestamp}/${this.expireTime}`;
let signinKey = _.hmac(authString, this.secretKey, 'sha256');
let header = {
'host': this.host,
'x-bce-date': _.urlencode(this.utcTimestamp)
};
let headerArr = [];
for (let name in header) {
let val = header[name];
headerArr.push(`${name}:${val}`);
}
let headerKeyStr = Object.keys(header).sort().join(';');
let requestStr = `${method}\n${uri}\n\n${headerArr.join('\n')}`;
let signautre = _.hmac(requestStr, signinKey, 'sha256');
return `${authString}/${headerKeyStr}/${signautre}`;
}
Trends.prototype.getToken = function () {
return _.hmac(this.userKey + this.timestamp, this.userSecret);
}
Trends.prototype.httpRequest = async function (method, url, params, headers) {
let urlObj = URL.parse(url);
let protocol = urlObj.protocol;
let options = {
hostname: urlObj.hostname,
port: urlObj.port,
path: urlObj.path,
method: method,
headers: headers,
timeout: 10000,
};
let postData = qs.stringify(params || {});
return new Promise((resolve, reject) => {
let req = (protocol == 'http:' ? http : https).request(options, (res) => {
let chunks = [];
res.on('data', (data) => {
chunks.push(data);
});
res.on('end', () => {
let buffer = Buffer.concat(chunks);
let encoding = res.headers['content-encoding'];
if (encoding == 'gzip') {
zlib.unzip(buffer, function (err, decoded) {
resolve(decoded.toString());
});
} else if (encoding == 'deflate') {
zlib.inflate(buffer, function (err, decoded) {
resolve(decoded.toString());
});
} else {
resolve(buffer.toString());
}
});
});
req.on('error', (e) => {
_.error('request error', method, url, params, e);
resolve('');
});
req.on("timeout", (e) => {
_.error('request timeout', method, url, params, e);
resolve('');
})
if (method.toUpperCase() == 'POST') {
req.write(postData);
}
req.end();
});
}
module.exports = function () {
return new Script;
}
function Script() {}
Script.prototype.run = async function () {
let rst = this.getTaskList();
console.log(rst);
}
Script.prototype.getTaskList = async function () {
let params = {};
let method = 'post';
let uri = '/openapi/getTasklist';
let rst = await _.trends.getInstance().request(method, uri, params);
return rst;
}
module.exports = function () {
return new Script;
}
function Script() {}
Script.prototype.run = async function () {
let rst = this.getTaskList();
console.log(rst);
}
Script.prototype.getTaskList = async function () {
let params = {};
let method = 'post';
let uri = '/openapi/getTasklist';
let rst = await _.trends.getInstance().request(method, uri, params);
return rst;
}
希望本文所述对大家node.js程序设计有所帮助。
刚刚发布热门点击发布时间
- [07/09]Chrome抓取页面内容代码|chrome插件获取页面数据
- [07/09]谷歌浏览器数据采集插件开发|谷歌浏览器的采集功能
- [07/09]Chrome插件轻松抓取网络数据,Chrome插件轻松抓取网页源码数据
- [07/09]chrome插件怎么安装?chrome插件开发如何安装chrome插件
- [07/09]快速chrome插件开发-北京chrome插件开发外包
- [12/31]清大光德落地护眼灯|清大光德儿童护眼灯
- [07/20]网站无障碍适老化外包改造私有化过程遇到问题整理
- [07/19]适老化改造工信部明确APP适老化规范：禁广告弹窗，网站需提供特大字体
- [07/19]适老化改造包括哪些方面?
- [07/19]什么是适老化改造？
- [07/19]适老化与信息无障碍是什么关系，二者有何异同？
- [07/19]网站如何进行适老化改造？
- [07/12]老年群体面临“数字鸿沟” 数字化网站适老化改造服务彰显人文关怀
- [07/12]数字适老化改造方案 老龄群体数字化改造受关注
- [07/11]什么是重绘?什么是回流?常见引起回流属性和方法：
