Pymongo конвертирует метку времени в дату как новое поле - PullRequest
Новая
       30

Pymongo конвертирует метку времени в дату как новое поле

0 голосов
/ 13 июня 2019

В моей коллекции много сущностей, и я должен создать новое поле даты в коллекции, чтобы использовать его для будущих запросов. 

{'_id': ObjectId('5afea920d326051990a7f337'), 'created_at': 'Fri May 18 10:21:07 +0000 2018', 'timestamp_ms': '1526638867739'}
{'_id': ObjectId('5afea920d326051990a7f339'), 'created_at': 'Fri May 18 10:21:08 +0000 2018', 'timestamp_ms': '1526638868310'}
{'_id': ObjectId('5afea972d326051c5c05bc11'), 'created_at': 'Fri May 18 10:22:30 +0000 2018', 'timestamp_ms': '1526638950799'}
{'_id': ObjectId('5afea974d326051c5c05bc16'), 'created_at': 'Fri May 18 10:22:32 +0000 2018', 'timestamp_ms': '1526638952160'}
{'_id': ObjectId('5afea974d326051c5c05bc17'), 'created_at': 'Fri May 18 10:22:32 +0000 2018', 'timestamp_ms': '1526638952841'}

Мне нужно преобразовать timestamp_ms в формат даты, например: 

{'_id': ObjectId('5afea920d326051990a7f337'), 'created_at': 'Fri May 18 10:21:07 +0000 2018', 'timestamp_ms': '1526638867739’, 'NewDate': '2018 05 18 10:21:07'}
{'_id': ObjectId('5afea920d326051990a7f339'), 'created_at': 'Fri May 18 10:21:08 +0000 2018', 'timestamp_ms': '1526638868310’, 'NewDate': '2018 05 18 10:21:08'}
{'_id': ObjectId('5afea972d326051c5c05bc11'), 'created_at': 'Fri May 18 10:22:30 +0000 2018', 'timestamp_ms': '1526638950799’, 'NewDate': '2018 05 18 10:22:30'}
{'_id': ObjectId('5afea974d326051c5c05bc16'), 'created_at': 'Fri May 18 10:22:32 +0000 2018', 'timestamp_ms': '1526638952160’, 'NewDate': '2018 05 18 10:22:32'}
{'_id': ObjectId('5afea974d326051c5c05bc17'), 'created_at': 'Fri May 18 10:22:32 +0000 2018', 'timestamp_ms': '1526638952841’, 'NewDate': '2018 05 18 10:22:32'}

Я использовал этот код (Python 3.6, pymongo 3.8, mongodb 4.0): 

pipeline = [
    {
        '$addFields': {
            'newDate': {
                '$toDate': '$timestamp_ms'
            }
        }
    }
]
cursor = collection.aggregate(pipeline)

Но выдает это сообщение об ошибке: pymongo.errors.OperationFailure: Error parsing date string '1526638867739'; 12: Unexpected character '9'

Я не уверен, чтоагрегат является правильным методом для этой задачи.datetime.strptime() может быть лучше для 'created_at', но я не понял, как реализовать это в db.Mycollection_update_many().

Ответы [ 2 ]

0 голосов
/ 22 июля 2019

Я получил ответ на свой вопрос от Каники Сингла на дискуссионном форуме университета MongoDB. Ответ здесь, если у вас такая же проблема. 

pipeline = [
    {
        '$project': {
            'yearMonthDayUTC': {
                '$convert': {
                    'to': 'double',
                    'input': '$timestamp_ms'
                }
            }
        }
    }, {
        '$addFields': {
            'newDate': {
                '$toDate': '$yearMonthDayUTC'
            }
        }
    }
]
0 голосов
/ 13 июня 2019

Используйте приведенный ниже запрос с pymongo и mongodb 4.0 

db.test.aggregate(
    [
        {
            "$addFields": {
                "NewDate": {"$toDate": "$timestamp_ms"} 
            }
        },
        {
            "$out": "test"
        },
    ],
)
...