在 Python 中将多个 JSON 写入 CSV - 字典到 CSV

Question

我正在使用 Tweepy 流式传输推文，并希望以 CSV 格式记录它们，以便我可以使用它们或稍后将它们加载到数据库中。 请记住，我是一个菜鸟，但我确实意识到有多种方法可以处理这个问题（非常欢迎提出建议）。

长话短说，我需要将多个 Python 字典转换并附加到 CSV 文件中。 我已经进行了研究 (How do I write a Python dictionary to a csv file?) 并尝试使用 DictWriter 和 writer 方法进行此操作。

但是，还有一些事情需要完成：

1) 仅将密钥作为标题写入一次。

2) 随着新推文的流式传输，需要在不覆盖之前行的情况下附加值。

3) 如果 value 缺少记录 NULL。

4) 跳过/修复 ascii 编解码器错误。

这是我想要最终得到的格式（每个值都在其单独的单元格中）：

Header1_Key_1 Header2_Key_2 Header3_Key_3...

Row1_Value_1 Row1_Value_2 Row1_Value_3...

Row2_Value_1 Row2_Value_2 Row2_Value_3...

Row3_Value_1 Row3_Value_2 Row3_Value_3...

Row4_Value_1 Row4_Value_2 Row4_Value_3...

这是我的代码：

from tweepy.streaming import StreamListener
from tweepy import OAuthHandler
from tweepy import Stream
import csv
import json

consumer_key="XXXX"
consumer_secret="XXXX"
access_token="XXXX"
access_token_secret="XXXX"

class StdOutListener(StreamListener):

    def on_data(self, data):
        json_data = json.loads(data)

        data_header = json_data.keys()
        data_row = json_data.values()

        try:
            with open('csv_tweet3.csv', 'wb') as f:
                w = csv.DictWriter(f, data_header)
                w.writeheader(data_header)
                w.writerow(json_data)
        except BaseException, e:
            print 'Something is wrong', str(e)

        return True

    def on_error(self, status):
        print status

if __name__ == '__main__':
    l = StdOutListener()
    auth = OAuthHandler(consumer_key, consumer_secret)
    auth.set_access_token(access_token, access_token_secret)

    stream = Stream(auth, l)
    stream.filter(track=['world cup'])

提前谢谢你！

Answer 1

我用 facebook 的图形 API（facepy 模块）做了类似的事情！

from tweepy.streaming import StreamListener
from tweepy import OAuthHandler
from tweepy import Stream
import csv
import json

consumer_key="XXXX"
consumer_secret="XXXX"
access_token="XXXX"
access_token_secret="XXXX"

class StdOutListener(StreamListener):
    _headers = None
    def __init__(self,headers,*args,**keys):
        StreamListener.__init__(self,*args,**keys)
        self._headers = headers

    def on_data(self, data):
        json_data = json.loads(data)

        #data_header = json_data.keys()
        #data_row = json_data.values()

        try:
            with open('csv_tweet3.csv', 'ab') as f: # a for append
                w = csv.writer(f)
                # write!
                w.writerow(self._valToStr(json_data[header])
                           if header in json_data else ''
                           for header in self._headers)
        except Exception, e:
            print 'Something is wrong', str(e)

        return True

    @static_method
    def _valToStr(o):
        # json returns a set number of datatypes - parse dependingly
        # https://docs.python.org/2/library/json.html#encoders-and-decoders
        if type(o)==unicode: return self._removeNonASCII(o)
        elif type(o)==bool: return str(o)
        elif type(o)==None: return ''
        elif ...
        ...

    def _removeNonASCII(s):
        return ''.join(i if ord(i)<128 else '' for i in s)

    def on_error(self, status):
        print status

if __name__ == '__main__':
    headers = ['look','at','twitter','api',
               'to','find','all','possible',
               'keys']

    # initialize csv file with header info
    with open('csv_tweet3.csv', 'wb') as f:
        w = csv.writer(headers)

    l = StdOutListener(headers)
    auth = OAuthHandler(consumer_key, consumer_secret)
    auth.set_access_token(access_token, access_token_secret)

    stream = Stream(auth, l)
    stream.filter(track=['world cup'])

它还没有准备好复制和粘贴，但它已经足够清楚了，你应该能够完成它。
为了提高性能，您可能希望查看打开文件，写入几条记录，然后关闭文件。这样您就不会一直打开、初始化 csv 编写器、追加，然后关闭文件。我不熟悉 tweepy API，所以我不确定它到底是如何工作的 - 但值得研究。

如果您遇到任何麻烦，我很乐意提供帮助 - 尽情享受吧！