00223 :
00224
00225 sqlcontext, task, subsite = "1=1", -1, -1
00226 vrb = kls.GetTableProxy().MakeValidityRecBuilder( sqlcontext, subsite, task )
00227 mpr = Mapr()
00228
00229 gDbi.level = "WARNING"
00230
00231 for vrec in sorted(vrb, key=lambda _:_.seqno):
00232 mpr.vrec = vrec
00233
00234 rpt = kls.Rpt().Clone()
00235 rpt.ctx( validityrec=vrec )
00236 n = len(rpt)
00237 log.info("seqno %s count %s digest %s" % ( vrec.seqno, n, rpt.digest ))
00238
00239 with Rollback(vrec.insertdate):
00240 for i,row in enumerate(rpt):
00241 sid = row.sensorid
00242 cid = mpr(sid)
00243 log.debug(" %-4s sensorid %-25s channelid %-25s " % ( i+1, sid.asString(), cid.asString() ))
00244 pass
00245 pass
00246
00247