Mercurial > code > home > repos > homeauto
diff service/beacon/rssiscan.py @ 1265:1ddd1f057749
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 |
line wrap: on
line diff
--- a/service/beacon/rssiscan.py Sat Apr 20 23:33:39 2019 -0700 +++ b/service/beacon/rssiscan.py Sat Apr 20 23:35:46 2019 -0700 @@ -176,21 +176,22 @@ rows = list(evt_le_advertising_report_dump(pkt)) for row in sorted(rows): rssi = row.pop('rssi') - points.append(dict( - measurement='rssi', - tags={'from': source, 'toAddr': row['addr']}, - fields={'value': rssi}, - time=nowMs, - )) - key = (row['addr'], row['evt_type']) - if lastDoc.get(key) != row: - # should check mongodb here- maybe another - # node already wrote this row - lastDoc.put(key, row) - row = row.copy() - row['t'] = now - coll.insert(row) - + if row['addr_type'] == 'Public': # or, someday, if it's a device we know + points.append(dict( + measurement='rssi', + tags={'from': source, 'toAddr': row['addr']}, + fields={'value': rssi}, + time=nowMs, + )) + key = (row['addr'], row['evt_type']) + if lastDoc.get(key) != row: + # should check mongodb here- maybe another + # node already wrote this row + lastDoc.put(key, row) + row = row.copy() + row['t'] = now + coll.insert(row) + influx.write_points(points, time_precision='ms') sock.setsockopt( bluez.SOL_HCI, bluez.HCI_FILTER, old_filter )