最佳答案
我在使用 json.load 转换为 dict 对象时遇到了麻烦,而且我不知道自己哪里做错了。运行这个程序的确切错误是
ValueError: Expecting property name: line 1 column 2 (char 1)
这是我的代码:
from kafka.client import KafkaClient
from kafka.consumer import SimpleConsumer
from kafka.producer import SimpleProducer, KeyedProducer
import pymongo
from pymongo import MongoClient
import json
c = MongoClient("54.210.157.57")
db = c.test_database3
collection = db.tweet_col
kafka = KafkaClient("54.210.157.57:9092")
consumer = SimpleConsumer(kafka,"myconsumer","test")
for tweet in consumer:
print tweet.message.value
jsonTweet=json.loads(({u'favorited': False, u'contributors': None})
collection.insert(jsonTweet)
我很确定错误发生在倒数第二行
jsonTweet=json.loads({u'favorited': False, u'contributors': None})
但是我不知道该怎么做才能解决这个问题。如果您能给我一些建议,我将不胜感激。