Revision 54598
Added by Sandro La Bruzzo about 4 years ago
| modules/s3-objectStore-migration/trunk/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
added skip store functionality