compute point difference with sets
This commit is contained in:
1 parent
74b3b6d73b
commit
575d9f275b
1 file changed
+7
-10
+7
-10
@@ -113,6 +113,11 @@ def main():
|
|||||||
dataSourceId=dataSourceId,
|
dataSourceId=dataSourceId,
|
||||||
datasetId=datasetId).execute()
|
datasetId=datasetId).execute()
|
||||||
|
|
||||||
|
def PointsDifference(left, right):
|
||||||
|
return len(
|
||||||
|
set(point['startTimeNanos'] for point in left['point']) -
|
||||||
|
set(point['startTimeNanos'] for point in right['point']))
|
||||||
|
|
||||||
command = 'patch'
|
command = 'patch'
|
||||||
if len(sys.argv) > 1:
|
if len(sys.argv) > 1:
|
||||||
command = sys.argv[1]
|
command = sys.argv[1]
|
||||||
@@ -136,11 +141,7 @@ def main():
|
|||||||
dataSourceId=dataSourceId,
|
dataSourceId=dataSourceId,
|
||||||
datasetId=datasetId).execute()
|
datasetId=datasetId).execute()
|
||||||
dataPost = GetData()
|
dataPost = GetData()
|
||||||
count = 0
|
print "Deleted %d points" % PointsDifference(dataPrior, dataPost)
|
||||||
for point in dataPrior['point']:
|
|
||||||
if not PointInData(point['startTimeNanos'], dataPost):
|
|
||||||
count = count + 1
|
|
||||||
print "Deleted %d points" % count
|
|
||||||
|
|
||||||
# Upload weight dataset.
|
# Upload weight dataset.
|
||||||
elif command == 'patch':
|
elif command == 'patch':
|
||||||
@@ -156,11 +157,7 @@ def main():
|
|||||||
point=googleWeightLogs,
|
point=googleWeightLogs,
|
||||||
)).execute()
|
)).execute()
|
||||||
dataPost = GetData()
|
dataPost = GetData()
|
||||||
count = 0
|
print "Added %d points" % PointsDifference(dataPost, dataPrior)
|
||||||
for point in dataPost['point']:
|
|
||||||
if not PointInData(point['startTimeNanos'], dataPrior):
|
|
||||||
count = count + 1
|
|
||||||
print "Added %d points" % count
|
|
||||||
|
|
||||||
else:
|
else:
|
||||||
print "bad command"
|
print "bad command"
|
||||||
|
|||||||
Reference in new issue
Block a user