如何等待 sparql 请求并在 nodejs 应用程序中设置变量?
how can I await a sparql request and set a variable in a nodejs app?
我是 sparql 和 nodejs 的新手,想查询 dbpedia 设置一个变量并将其传递给前端。但是,如果我 运行 我的代码,我可以 console.log 请求的数据,但我不会将其传递到前端。我正在使用 sparql-http-client js。
我会很感激任何提示。我确实很难理解异步。
const SparqlClient = require('sparql-http-client');
exports.sparql = async (req,res) =>{
console.log('going to sparql … ' + req.query.eventSearchbar);
let searchterm = req.query.eventSearchbar;
let comment = 'not set';
const endpointUrl = 'http://dbpedia.org/sparql';
const query = `
PREFIX res: <http://dbpedia.org/resource/>
SELECT ?comment
WHERE
{
res:${searchterm} rdfs:comment ?comment
FILTER(lang(?comment)="en")
}`;
console.log(query);
const client = new SparqlClient({ endpointUrl });
const stream = await client.query.select(query);
stream.on('data', row => {
Object.entries(row).forEach(([key, value]) => {
comment = `${key}: ${value.value} (${value.termType})`;
console.log(comment);
});
});
stream.on('error', err => {
console.error(err);
});
res.render('search',{searchterm: searchterm, wikiDescription: comment });
}
我会在流结束并写入所有数据后尝试 运行 res.render('search',{searchterm: searchterm, wikiDescription: comment });
。像下面这样的东西。您现在拥有的方式是,在读取数据之前(或同时)立即运行该行。
stream.on('end', () => {
res.render('search',{searchterm: searchterm, wikiDescription: comment });
}
这个 resource 可能对一些例子有帮助。
我是 sparql 和 nodejs 的新手,想查询 dbpedia 设置一个变量并将其传递给前端。但是,如果我 运行 我的代码,我可以 console.log 请求的数据,但我不会将其传递到前端。我正在使用 sparql-http-client js。 我会很感激任何提示。我确实很难理解异步。
const SparqlClient = require('sparql-http-client');
exports.sparql = async (req,res) =>{
console.log('going to sparql … ' + req.query.eventSearchbar);
let searchterm = req.query.eventSearchbar;
let comment = 'not set';
const endpointUrl = 'http://dbpedia.org/sparql';
const query = `
PREFIX res: <http://dbpedia.org/resource/>
SELECT ?comment
WHERE
{
res:${searchterm} rdfs:comment ?comment
FILTER(lang(?comment)="en")
}`;
console.log(query);
const client = new SparqlClient({ endpointUrl });
const stream = await client.query.select(query);
stream.on('data', row => {
Object.entries(row).forEach(([key, value]) => {
comment = `${key}: ${value.value} (${value.termType})`;
console.log(comment);
});
});
stream.on('error', err => {
console.error(err);
});
res.render('search',{searchterm: searchterm, wikiDescription: comment });
}
我会在流结束并写入所有数据后尝试 运行 res.render('search',{searchterm: searchterm, wikiDescription: comment });
。像下面这样的东西。您现在拥有的方式是,在读取数据之前(或同时)立即运行该行。
stream.on('end', () => {
res.render('search',{searchterm: searchterm, wikiDescription: comment });
}
这个 resource 可能对一些例子有帮助。