print count added and deleted
This commit is contained in:
1 parent
a2a316a582
commit
74b3b6d73b
1 file changed
+29
-6
+29
-6
@@ -107,16 +107,19 @@ def main():
|
|||||||
|
|
||||||
datasetId = '%s-%s' % (minLogNs, maxLogNs)
|
datasetId = '%s-%s' % (minLogNs, maxLogNs)
|
||||||
|
|
||||||
|
def GetData():
|
||||||
|
return googleClient.users().dataSources().datasets().get(
|
||||||
|
userId='me',
|
||||||
|
dataSourceId=dataSourceId,
|
||||||
|
datasetId=datasetId).execute()
|
||||||
|
|
||||||
command = 'patch'
|
command = 'patch'
|
||||||
if len(sys.argv) > 1:
|
if len(sys.argv) > 1:
|
||||||
command = sys.argv[1]
|
command = sys.argv[1]
|
||||||
|
|
||||||
# Get weight dataset.
|
# Get weight dataset.
|
||||||
if command == 'get':
|
if command == 'get':
|
||||||
data = googleClient.users().dataSources().datasets().get(
|
data = GetData()
|
||||||
userId='me',
|
|
||||||
dataSourceId=dataSourceId,
|
|
||||||
datasetId=datasetId).execute()
|
|
||||||
for point in data['point']:
|
for point in data['point']:
|
||||||
startTimeNanos = point['startTimeNanos']
|
startTimeNanos = point['startTimeNanos']
|
||||||
fpVal = point['value'][0]['fpVal']
|
fpVal = point['value'][0]['fpVal']
|
||||||
@@ -127,15 +130,22 @@ def main():
|
|||||||
|
|
||||||
# Delete weight dataset.
|
# Delete weight dataset.
|
||||||
elif command == 'delete':
|
elif command == 'delete':
|
||||||
|
dataPrior = GetData()
|
||||||
googleClient.users().dataSources().datasets().delete(
|
googleClient.users().dataSources().datasets().delete(
|
||||||
userId='me',
|
userId='me',
|
||||||
dataSourceId=dataSourceId,
|
dataSourceId=dataSourceId,
|
||||||
datasetId=datasetId).execute()
|
datasetId=datasetId).execute()
|
||||||
print "deleted data"
|
dataPost = GetData()
|
||||||
|
count = 0
|
||||||
|
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':
|
||||||
print googleClient.users().dataSources().datasets().patch(
|
dataPrior = GetData()
|
||||||
|
googleClient.users().dataSources().datasets().patch(
|
||||||
userId='me',
|
userId='me',
|
||||||
dataSourceId=dataSourceId,
|
dataSourceId=dataSourceId,
|
||||||
datasetId=datasetId,
|
datasetId=datasetId,
|
||||||
@@ -145,10 +155,23 @@ def main():
|
|||||||
minStartTimeNs=minLogNs,
|
minStartTimeNs=minLogNs,
|
||||||
point=googleWeightLogs,
|
point=googleWeightLogs,
|
||||||
)).execute()
|
)).execute()
|
||||||
|
dataPost = GetData()
|
||||||
|
count = 0
|
||||||
|
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"
|
||||||
|
|
||||||
|
|
||||||
|
def PointInData(startTimeNanos, data):
|
||||||
|
if 'point' in data:
|
||||||
|
for point in data['point']:
|
||||||
|
if startTimeNanos == point['startTimeNanos']:
|
||||||
|
return True
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
main()
|
main()
|
||||||
Reference in new issue
Block a user