python - 维护一个包含与给定标签匹配的推文的 mongodb

Question

我必须保留一个包含与给定标签匹配的推文的 mongodb。另外，我必须用推文的最新数据来更新它。我需要将索引创建为“id_str”。当我运行此代码时出现异常，但不知道为什么。我只知道“for”有问题。

def getSearchTagTwitter(tag):

  db = connexMongoDB()
  t = loginTwython2()
  search = t.search(q=tag, count=100)
  data = search['statuses']
  try:
      for tweet in data:
          db.twittersearch.ensureIndex(tweet['id_str'])
          db.twittersearch.update(tweet)
  except Exception:
      print "Error tag"
      time.sleep(60*15)
      getSearchTagTwitter(tag)

Answer 1

我认为该错误是由 ensureIndex 引发的，因为语法看起来不太正确。正确的语法是:

db.twittersearch.ensureIndex('id_str')

也不需要在 for 循环的每次迭代中创建索引，只需声明一次，它就会自动更新。请注意，ensureIndex 现已弃用，您应该使用 create_index。

此外，您的 update 语句看起来也不正确，应如下所示:

 db.twittersearch.update_one({"id_str":"12344"}, tweet, upsert=True)