code = 2200 [無效的查詢] message =「密鑰可能不是空的」

Question

我試圖插入Python字典，並且在寫入cassandra DB時出現了code=2200 [Invalid query] message="Key may not be empty"錯誤。有誰知道發生了什麼事？

卡桑德拉作者：

def writer(**kwargs): 
    try: 
     openEventStream.create(
      venue_name = get_dict_val(kwargs, 'venue_name'), 
      venue_lon = get_dict_val(kwargs, 'venue_lon'), 
      .... 
     ) 
    except Exception, e: 
     print e 

其實寫入卡桑德拉：

def fetch_data(messages): 
    for message in messages: 
     # venue 
     venue = get_dict_val(message, 'venue') 
     if venue: 
      venue_name = get_dict_val(venue, 'venue_name') 
      venue_lon = get_dict_val(venue, 'venue_lon') 
      ... 
     else: 
      venue_name, venue_lon = None, None     

     writer(venue_name = venue_name, venue_lon = venue_lon) 

然後執行：

fetch_data(some_nested_dict) 

Answer 1

看起來要麼你是不是在你的所有分區插入數據鍵或在所有聚類列中。