Zapytania do innych scraperów
await this.parser.request(parser, preset, overrideParams, query)
await this.parser.request(parser, preset, overrideParams, query)
Pobieranie wyników z innego scrapera (wbudowanego lub innego scrapera JS), jako argumenty podaje się:
parser- nazwa scrapera (SE::Google, JS::Custom::Example)preset- preset ustawień wywoływanego scraperaoverrideParams- hash z nadpisaniem ustawień wywoływanego scraperaquery- zapytanie
Częściowo ignoruje preset wywoływanego scrapera, który jest określany przez parametr preset. Mianowicie, ustawienia useproxy, proxyChecker, proxybannedcleanup są pobierane ze scrapera, który wywołuje await this.parser.request.
W overrideParams można nadpisywać parametry wywoływanego scrapera, dostępne są również następujące flagi:
overrideParams.resultArraysWithObjects
resultArraysWithObjects: 0 - określa, w jakiej formie zwracać tablice wyników wywoływanego scrapera:
- jeśli włączone (1) - będą zwracane tablice obiektów
[{link: 'link1', anchor: 'anchor1'}, {link: 'link2', anchor: 'anchor2'}, ...] - jeśli wyłączone (0) - będą zwracane standardowe tablice wartości
['link1', 'anchor1', 'link2', 'anchor2', ...]
Przykład:
import { BaseParser } from 'a-parser-types';
class JS_DocExample extends BaseParser {
static defaultConf: typeof BaseParser.defaultConf = {
results_format: "$links.format('$link\n')",
results: {
arrays: {
links: ['Links', [
['link', 'link']
]]
}
}
}
async parse(set, results) {
let response = await this.parser.request('SE::Google', 'default', {
resultArraysWithObjects: 1,
pagecount: 1
}, set.query)
results.success = response.success;
if(response.success) {
response.serp.forEach(element => {
results.links.push(element.link);
});
}
return results;
}
}
Przykład wyniku:
https://www.speedtest.net/
https://www.investopedia.com/terms/t/t-test.asp
https://www.cdc.gov/coronavirus/2019-ncov/testing/diagnostic-testing.html
https://fast.com/
https://www.thinkwithgoogle.com/feature/testmysite/
https://projectstream.google.com/speedtest
https://www.nhs.uk/conditions/coronavirus-covid-19/testing/
https://www.fda.gov/consumers/consumer-updates/coronavirus-disease-2019-testing-basics
https://zoom.us/test
https://www.gov.uk/get-coronavirus-test
https://en.wikipedia.org/wiki/Test_(assessment)
...
overrideParams.needData
needData: 1 - określa, czy przekazywać (1) czy nie (0) w odpowiedzi data/pages[], może być używane do optymalizacji
overrideParams.needResults
needResults: [ ... ] - lista wyników, które należy zwrócić.
Przykład:
let response = await this.parser.request('SE::Bing', 'default', {
needResults: [
'totalcount'
]
}, set.query)
Wynik:
{"success":1,"info":{"success":1,"retries":0},"totalcount":"2130000000"}
Działa analogicznie dla
API::Server::Redis
overrideParams.skipProxySettingsInheritance
skipProxySettingsInheritance: 0 - ta opcja pozwala wyłączyć dziedziczenie parametru useproxy dla wywoływanego scrapera
Zapytania do scraperów obsługujących tryb pakietowy
Obsługiwane jest również odwoływanie się do scraperów pracujących w trybie pakietowym. W tym celu w query należy przekazać tablicę zapytań w formacie ['key1', 'key2', ...].
Wynik przetwarzania przez wywoływany scraper będzie zawarty w tablicy bulkResults, poniżej przykład takiej tablicy:
{
"bulkResults": [
{
"success": 1,
"someArrayResult": [...],
"someFlatResult": '...',
"query": "key1",
"data": "..."
},
{
"success": 1,
"someArrayResult": [...],
"someFlatResult": '...',
"query": "key2",
"data": "..."
},
{
"success": 1,
"someArrayResult": [...],
"someFlatResult": '...',
"query": "key3",
"data": "..."
}
],
"success": 1,
"info": {
"success": 1,
"retries": 1
}
}
Przykład odwołania do innego scrapera w trybie pakietowym
import { BaseParser } from 'a-parser-types';
export class JS_Example_BulkQueries extends BaseParser {
static defaultConf: typeof BaseParser.defaultConf = {
version: '1.0.0',
results: {
flat: [
['views', 'Views count per month']
]
},
results_format: "$query: $views\\n",
SE_Yandex_Direct_Frequency_preset: 'default',
bulkQueries: 10 // ustawiamy liczbę zapytań w "paczce"
};
static editableConf: typeof BaseParser.editableConf = [
['SE_Yandex_Direct_Frequency_preset', ['combobox', 'SE::Yandex::Direct::Frequency preset']]
];
async parse(set, results) {
const { success, bulkResults } = await this.parser.request(
'SE::Yandex::Direct::Frequency',
this.conf.SE_Yandex_Direct_Frequency_preset,
{ useAccounts: 1 },
set.bulkQueries.map((el) => el.query) // przekształcamy tablicę obiektów set.bulkQueries na tablicę typu [query1, query2, ... query10]
);
if(success) {
// wypełniamy wyniki w results.bulkResults
for(let query_number = 0; query_number < set.bulkQueries.length; query_number++) {
results.bulkResults[query_number].views = bulkResults[query_number].views;
results.bulkResults[query_number].success = bulkResults[query_number].success;
}
}
return results;
}
}