密鑰不得包含。錯誤pymongo

Question

我想通過pymongo獲取serverStatus命令的輸出，然後將其插入到mongodb集合中。這裏是字典

{u'metrics': {u'getLastError': {u'wtime': {u'num': 0, u'totalMillis': 0}, u'wtimeouts': 0L}, u'queryExecutor': {u'scanned': 0L}, u'record': {u'moves': 0L}, u'repl': {u'buffer': {u'count': 0L, u'sizeBytes': 0L, u'maxSizeBytes': 268435456}, u'apply': {u'batches': {u'num': 0, u'totalMillis': 0}, u'ops': 0L}, u'oplog': {u'insert': {u'num': 0, u'totalMillis': 0}, u'insertBytes': 0L}, u'network': {u'bytes': 0L, u'readersCreated': 0L, u'getmores': {u'num': 0, u'totalMillis': 0}, u'ops': 0L}, u'preload': {u'docs': {u'num': 0, u'totalMillis': 0}, u'indexes': {u'num': 0, u'totalMillis': 0}}}, u'ttl': {u'passes': 108L, u'deletedDocuments': 0L}, u'operation': {u'fastmod': 0L, u'scanAndOrder': 0L, u'idhack': 0L}, u'document': {u'deleted': 0L, u'updated': 0L, u'inserted': 1L, u'returned': 0L}}, u'process': u'mongod', u'pid': 7073, u'connections': {u'current': 1, u'available': 818, u'totalCreated': 58L}, u'locks': {u'admin': {u'timeAcquiringMicros': {}, u'timeLockedMicros': {}}, u'local': {u'timeAcquiringMicros': {u'r': 1942L, u'w': 0L}, u'timeLockedMicros': {u'r': 72369L, u'w': 0L}}, u'.': {u'timeAcquiringMicros': {u'R': 218733L, u'W': 30803L}, u'timeLockedMicros': {u'R': 311478L, u'W': 145679L}}}, u'cursors': {u'clientCursors_size': 0, u'timedOut': 0, u'totalOpen': 0}, u'globalLock': {u'totalTime': 6517358000L, u'lockTime': 145679L, u'currentQueue': {u'total': 0, u'writers': 0, u'readers': 0}, u'activeClients': {u'total': 0, u'writers': 0, u'readers': 0}}, u'extra_info': {u'note': u'fields vary by platform', u'page_faults': 21, u'heap_usage_bytes': 62271152}, u'uptime': 6518.0, u'network': {u'numRequests': 103, u'bytesOut': 106329, u'bytesIn': 6531}, u'uptimeMillis': 6517358L, u'recordStats': {u'local': {u'pageFaultExceptionsThrown': 0, u'accessesNotInMemory': 0}, u'pageFaultExceptionsThrown': 0, u'accessesNotInMemory': 0}, u'version': u'2.4.8', u'dur': {u'compression': 0.0, u'journaledMB': 0.0, u'commits': 30, u'writeToDataFilesMB': 0.0, u'commitsInWriteLock': 0, u'earlyCommits': 0, u'timeMs': {u'writeToJournal': 0, u'dt': 3077, u'remapPrivateView': 0, u'prepLogBuffer': 0, u'writeToDataFiles': 0}}, u'mem': {u'resident': 36, u'supported': True, u'virtual': 376, u'mappedWithJournal': 160, u'mapped': 80, u'bits': 64}, u'opcountersRepl': {u'getmore': 0, u'insert': 0, u'update': 0, u'command': 0, u'query': 0, u'delete': 0}, u'indexCounters': {u'missRatio': 0.0, u'resets': 0, u'hits': 0, u'misses': 0, u'accesses': 0}, u'uptimeEstimate': 6352.0, u'host': u'kal-el', u'writeBacksQueued': False, u'localTime': datetime.datetime(2014, 1, 18, 8, 1, 30, 22000), u'backgroundFlushing': {u'last_finished': datetime.datetime(2014, 1, 18, 8, 0, 52, 713000), u'last_ms': 0, u'flushes': 108, u'average_ms': 1.1111111111111112, u'total_ms': 120}, u'opcounters': {u'getmore': 0, u'insert': 1, u'update': 0, u'command': 105, u'query': 108, u'delete': 0}, u'ok': 1.0, u'asserts': {u'msg': 0, u'rollovers': 0, u'regular': 0, u'warning': 0, u'user': 0}}

我得到「重點 ''不得含有「。錯誤。這裏可能是什麼問題？我沒有看到任何。在關鍵的名字。

這裏是回溯：

Traceback (most recent call last): 
    File "src/mongodb_status.py", line 37, in <module> 
    get_mongodb_status() 
    File "src/mongodb_status.py", line 23, in get_mongodb_status 
    md_status.insert(status_data) 
    File "/home/guruprasad/dev/py/src/dnacraft_monitor_servers/venv/local/lib/python2.7/site-packages/pymongo/collection.py", line 362, in insert 
    self.database.connection) 
bson.errors.InvalidDocument: key '.' must not contain '.' 

Answer 1

在14行：「與 '

u'.': {u'timeAcquiringMicros': {u'R': 218733L, u'W': 30803L}, u'timeLockedMicros': {u'R': 311478L, u'W': 145679L}}} 

對於未來的安全性，通過按鍵進行迭代，更換_' 什麼的，然後執行寫入。

Answer 2

這是一個將刪除'。'的函數。從你的密鑰：

def fix_dict(data, ignore_duplicate_key=True): 
    """ 
    Removes dots "." from keys, as mongo doesn't like that. 
    If the key is already there without the dot, the dot-value get's lost. 
    This modifies the existing dict! 

    :param ignore_duplicate_key: True: if the replacement key is already in the dict, now the dot-key value will be ignored. 
           False: raise ValueError in that case. 
    """ 
    if isinstance(data, (list, tuple)): 
     list2 = list() 
     for e in data: 
      list2.append(fix_dict(e)) 
     # end if 
     return list2 
    if isinstance(data, dict): 
     # end if 
     for key, value in data.items(): 
      value = fix_dict(value) 
      old_key = key 
      if "." in key: 
       key = old_key.replace(".", "") 
       if key not in data: 
        data[key] = value 
       else: 
        error_msg = "Dict key {key} containing a \".\" was ignored, as {replacement} already exists".format(
         key=key_old, replacement=key) 
        if force: 
         import warnings 
         warnings.warn(error_msg, category=RuntimeWarning) 
        else: 
         raise ValueError(error_msg) 
        # end if 
       # end if 
       del data[old_key] 
      # end if 
      data[key] = value 
     # end for 
     return data 
    # end if 
    return data 
# end def