1
This commit is contained in:
parent
8573753689
commit
ca38b2f00a
@ -50,13 +50,21 @@ class BcSpider extends BaseTask {
|
|||||||
async outputProgressInfo(net, events) {
|
async outputProgressInfo(net, events) {
|
||||||
let count = 0;
|
let count = 0;
|
||||||
while (true) {
|
while (true) {
|
||||||
log.info('----------------------------------------------------------net_id:' + net['net_id'] + ' %d' + count);
|
log.info('----------------------------------------------------------');
|
||||||
events.forEach
|
events.forEach
|
||||||
(
|
(
|
||||||
(event) => {
|
(event) => {
|
||||||
const logObj = {
|
const eventConf = event['eventConf'];
|
||||||
|
const progInfo = event['progressInfo'];
|
||||||
};
|
const logObj = 'net_id: ' + net['net_id'] + ' ' +
|
||||||
|
eventConf['contract_name'] + '.' +
|
||||||
|
eventConf['event_name'] + ' ' +
|
||||||
|
' pullCount:' + progInfo['pullCount'] +
|
||||||
|
' eventCount:' + progInfo['eventCount'] +
|
||||||
|
' fromBlock:' + progInfo['fromBlock'] +
|
||||||
|
' toBlock:' + progInfo['toBlock'] +
|
||||||
|
' currBlock:' + progInfo['currBlock']
|
||||||
|
;
|
||||||
log.info(logObj);
|
log.info(logObj);
|
||||||
}
|
}
|
||||||
);
|
);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user