从 mongo 获取日期时间并将其推送到数组

Question

我有以下道具的文件：

{
   'published_date': '2020/03/10 07:20:09',
   'relationships': [
       {'rel_name': 'HAS_REL'},
       {'rel_name': 'HAS_NO_REL'},
    ]
}

我想在 relationships 的每个字段中添加 rel_name 的值 HAS_REL 作为属性 dict 的发布日期的值。文档会变成这样：

{
   'published_date': '2020/03/10 07:20:09',
   'relationships': [
       { 'rel_name': 'HAS_REL'
         'date': 2020,03,10,07,20,09
       },
       {'rel_name': 'HAS_NO_REL'},
    ]
}

到目前为止，我的查询看起来像这样：

TEST_COLLECTION.update_one(
  {'_id': ObjectId(document_id)},
  {'$set': {'relationships.$[elem].date': {'$dateFromString': '$published_date'}}},
  False,
  False,
  None,
  [{'elem.rel_name': 'HAS_RELATIONSHIP'}],
)

但我收到错误消息：

WriteError: The dollar ($) prefixed field '$dateFromString' in 'parsed.relationships.1.date.$dateFromString' is not valid for storage.

有什么想法吗？

更新根据最初的答案，我更新了如下查询：

TEST_COLLECTION.update_one(
    {'_id': ObjectId(document_id)},
    [
        {'$set': {
            'relationships': {
                '$let': {
                    'vars': {
                        'date': { '$dateFromString': { 'dateString': '$published_date', format: "%Y/%m/%d %H:%M:%S" } }
                    },
                    'in': {
                        '$map': {
                            'input': "$relationships",
                            'in': {
                                '$cond': {
                                      'if': { '$eq': ["$$this.rel_name", "HAS_REL"] },
                                      'then': { '$mergeObjects': ["$$this", { 'date': "$$date" }] },
                                      'else': "$$this"
                                   }
                                }
                             }
                          }
                       }
                    }
              }
         }
    ]
)

但是，我似乎没有得到正确的文件：

InvalidDocument: documents must have only string keys, key was built-in function format

Answer 1

看看$dateFromString

您必须指定 format 字段，除非您使用默认格式 "%Y-%m-%dT%H:%M:%S.%LZ"。将 date/time 值存储为字符串通常是一个设计缺陷。

所以，一定是

{'$dateFromString': { dateString: '$published_date', format: "%Y/%m/%d %H:%M:%S" } }

请注意，时间以 UTC 时间为准。如果需要，设置字段 timezone 以指定时区。

注意，$dateFromString()是聚合函数，所以必须使用

TEST_COLLECTION.update_one(
   { '_id': ObjectId(document_id) },
   [
      {
         $set: {
            relationships: {
               $map: {
                  input: "$relationships",
                  in: {
                     $cond: {
                        if: { $eq: ["$$this.rel_name", "HAS_REL"] },
                        then: {
                           $mergeObjects: [
                              "$$this",
                              {
                                 date: {
                                    $dateFromString: {
                                       dateString: '$published_date',
                                       format: "%Y/%m/%d %H:%M:%S"
                                    }
                                 }
                              }
                           ]
                        },
                        else: "$$this"
                     }
                  }
               }
            }
         }
      }
   ]
)

或其他风格：

TEST_COLLECTION.update_one(
   { '_id': ObjectId(document_id) },
   [
      {
         $set: {
            relationships: {
               $let: {
                  vars: {
                     date: { $dateFromString: { dateString: '$published_date', format: "%Y/%m/%d %H:%M:%S" } }
                  },
                  in: {
                     $map: {
                        input: "$relationships",
                        in: {
                           $cond: {
                              if: { $eq: ["$$this.rel_name", "HAS_REL"] },
                              then: { $mergeObjects: ["$$this", { date: "$$date" }] },
                              else: "$$this"
                           }
                        }
                     }
                  }
               }
            }
         }
      }
   ]
)

从 mongo 获取日期时间并将其推送到数组

get a datetime from mongo and push it to the array

mongodb

pymongo