Mercurial > code > home > repos > homeauto

comparison service/beacon/rssiscan.py @ 1265:1ddd1f057749

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
some old Measurement and Locator edits Ignore-this: 188ecdf63f49b7a58f99a5961c6c23a6 darcs-hash:53fc6d5070d1ac0ad286c9c4d59a85dc134f3f02
author drewp <drewp@bigasterisk.com>
date Sat, 20 Apr 2019 23:35:46 -0700
parents 0a864b90a0b4
children
comparison
equal deleted inserted replaced
1264:c5b13d630d90 1265:1ddd1f057749
174 pass 174 pass
175 elif subevent == EVT_LE_ADVERTISING_REPORT: 175 elif subevent == EVT_LE_ADVERTISING_REPORT:
176 rows = list(evt_le_advertising_report_dump(pkt)) 176 rows = list(evt_le_advertising_report_dump(pkt))
177 for row in sorted(rows): 177 for row in sorted(rows):
178 rssi = row.pop('rssi') 178 rssi = row.pop('rssi')
179 points.append(dict( 179 if row['addr_type'] == 'Public': # or, someday, if it's a device we know
180 measurement='rssi', 180 points.append(dict(
181 tags={'from': source, 'toAddr': row['addr']}, 181 measurement='rssi',
182 fields={'value': rssi}, 182 tags={'from': source, 'toAddr': row['addr']},
183 time=nowMs, 183 fields={'value': rssi},
184 )) 184 time=nowMs,
185 key = (row['addr'], row['evt_type']) 185 ))
186 if lastDoc.get(key) != row: 186 key = (row['addr'], row['evt_type'])
187 # should check mongodb here- maybe another 187 if lastDoc.get(key) != row:
188 # node already wrote this row 188 # should check mongodb here- maybe another
189 lastDoc.put(key, row) 189 # node already wrote this row
190 row = row.copy() 190 lastDoc.put(key, row)
191 row['t'] = now 191 row = row.copy()
192 coll.insert(row) 192 row['t'] = now
193 193 coll.insert(row)
194
194 influx.write_points(points, time_precision='ms') 195 influx.write_points(points, time_precision='ms')
195 sock.setsockopt( bluez.SOL_HCI, bluez.HCI_FILTER, old_filter ) 196 sock.setsockopt( bluez.SOL_HCI, bluez.HCI_FILTER, old_filter )
196 197
197 198
198 if __name__ == '__main__': 199 if __name__ == '__main__':