Implement indexing into Apache Druid #1
|
@ -225,6 +225,13 @@ def _initialList(net, num, listinfo, chanlimit):
|
||||||
p.hset(abase, "relay", relay)
|
p.hset(abase, "relay", relay)
|
||||||
p.hset(abase, "sigrelay", sigrelay)
|
p.hset(abase, "sigrelay", sigrelay)
|
||||||
p.hset(abase, "insigrelay", ceil(insiglength / chanlimit))
|
p.hset(abase, "insigrelay", ceil(insiglength / chanlimit))
|
||||||
|
debug(
|
||||||
|
(
|
||||||
|
f"_initialList() net:{net} num:{num} listlength:{listlength} "
|
||||||
|
f"mean:{mean} siglength:{siglength} insiglength:{insiglength} "
|
||||||
|
f"sigrelay:{sigrelay} relay:{relay} chanlimit:{chanlimit}"
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
# Purge existing records before writing
|
# Purge existing records before writing
|
||||||
# purgeRecords(net)
|
# purgeRecords(net)
|
||||||
|
|
Loading…
Reference in New Issue