Project

General

Profile

« Previous | Next » 

Revision 54598

added skip store functionality

View differences:

s3_migration.py
56 56
	for item in metadataCollection.find(no_cursor_timeout=True):
57 57
		obsId = item['obsId']
58 58
		if obsId not in skip_store:
59
			destination_collection = db[ 's3_'+obsId[:36]]
59 60
			destination_collection.create_index([('id',pymongo.ASCENDING)])
60 61
			exportItemForMongoCollection(obsId, db, bucket, log_file)
61
			destination_collection =db[ 's3_'+obsId[:36]]			
62 62
			done_file.write('{}\n'.format(obsId))
63 63

  
64 64

  

Also available in: Unified diff