r - 使用 mongolite R 将数据框附加到现有集合

Question

我有一个已经加载到 mongodb 的股票数据框。随着新信息的出现，我正在尝试添加每个新行是不同日期的行。但是，当我尝试插入我的新数据框时，我收到此错误:错误:E11000 重复键错误集合:timeSeries.patimeseries 索引:id dup 键:{_id:“5fb69a960438522a0631cca2”}
这是我目前正在做的

con = mongo(collection, db, url)

#look at existing data
con$find()

date         Price  Value2
2020-10-10   50      AAPL
2020-10-10   88      MSFT
2020-10-11   52      AAPL
2020-10-11   54      MSFT
                    

我在 2020 年 10 月 13 日收到了我希望插入的新数据。

print(new.df)
date        price  Value2
2020-10-12  56     AAPL
2020-10-12  92     MSFT

我做的第一件事是从我的数据库中删除日期“2020-10-13”，然后尝试插入新信息。

con$remove(
query = '{"date" : "2020-10-12"}'
)

con$insert(
new.df
)

 Error: E11000 duplicate key error collection: timeSeries.patimeseries index: _id_ dup key: { _id: "5fb69a960438522a0631cca2" }

Answer 1

看起来您正在删除数据而不是数据上的索引。由于日期数据被索引为 _id，因此无法删除。 (请参阅 https://api.mongodb.com/wiki/current/Indexes.html#Indexes-The%5CidIndex )您是否尝试使用更新查询，而不是尝试删除条目并在其位置创建新条目？

con$update('{"date" : "2020-10-13"}', '{"$set":{"price": 56}}')

见 https://jeroen.github.io/mongolite/manipulate-data.html#update-upsert用于文档。
注:如果您正在运行一些需要更新而其他需要插入的查询，您可以添加 upsert = TRUE如果没有找到匹配的记录，则执行插入。
更新:我没有看到任何用于执行批量更新的文档。如果不可能，一种解决方法是将每个数据帧转换为这样的 json 字符串列表:

library(rjson)
x <- split(df, 1:nrow(df))
json_strings <- lapply(x, toJSON)

在此示例中，每个 json 将由作为键的列名称和作为对应值的一行数据组成，因此您可以循环执行以下操作:

for (val in 1:length(df$date))
{
  this_date <- df$date[val]
  date_query <- paste('{"date" : ', as.character(this_date), '}')
  set_query <- paste('{"$set":', json_strings[val], '}')
  con$update(date_query, set_query)
}

可能有一种更干净的方法来完成所有这些。例如，您可以重构以消除循环，然后使用 dplyr动词(例如mutate)来构造json字符串，但其思想是根据数据帧中的数据生成json字符串，并动态执行更新查询。