Создание коллекции MongoDB в pymongo с именем коллекции на основе элемента из stringarray

Question

Im новый для python, так что легко на меня! Я пытаюсь реализовать прослушиватель потоков через tweepy, который передает твиты на основе фильтра ключевых слов (используется для этого массив строк) и сохраняет эти твиты в коллекции в mongodb (используя pymongo).

Я был успешным в этом, но теперь я хочу сделать это дальше, сохранив твиты, отфильтрованные определенной строкой из моего filterKeywords-массива, в коллекцию mongodb, названную после строкового элемента массива, который был отфильтрован (т. е. твит, отфильтрованный строковым элементом «Apple», который будет сохранен в коллекцию mongodb под названием «Apple».

Я попытался сделать это уже без везения через цикл for в методе on_data для циклического перехода по массиву и если элемент найден в твите, тогда попытайтесь создать коллекцию на основе этого ключевого элемента, но он просто создает коллекцию под названием «слово» и сохраняет ее в этом.

Вот мой код ниже (ive оставил мои учетные данные в twitter по очевидным причинам). Надеюсь, кто-то может помочь

import tweepy 
import pymongo 
import json 

consumer_key="" 
consumer_secret="" 
access_key = "" 
access_secret = "" 

auth = tweepy.OAuthHandler(consumer_key, consumer_secret) 
auth.set_access_token(access_key, access_secret) 
api = tweepy.API(auth) 

filterKeywords = ['IBM', 'Microsoft', 'Facebook', 'Twitter', 'Apple', 'Google', 'Amazon', 'EBay', 'Diageo', 
        'General Motors', 'General Electric', 'Telefonica', 'Rolls Royce', 'Walmart', 'HSBC', 'BP', 
        'Investec', 'WWE', 'Time Warner', 'Santander Group'] 


class CustomStreamListener(tweepy.StreamListener): 
    def __init__(self, api): 
     self.api = api 
     super(tweepy.StreamListener, self).__init__() 

     self.db = pymongo.MongoClient().mydb 


    def on_data(self, tweet): 
     data = json.loads(tweet) 
     for word in filterKeywords: 
      if word in data: 
       collection = self.db[word] 
       collection.insert(data), 
     print (tweet) 

    def on_error(self, status_code): 
     return True # Don't kill the stream 

    def on_timeout(self): 
     return True # Don't kill the stream 


sapi = tweepy.streaming.Stream(auth, CustomStreamListener(api)) 
sapi.filter(track=filterKeywords) 

Answer 1

я это фиксированный от ответа на другой вопрос, что я спросил, мой PyMongo код на самом деле работал это делать со мной загрузки твитов в формате JSON. Затем для этого нужно было проверить «ключ» для «текстового» ключа, чтобы проверить, содержит ли этот текст один из моих ключевых слов filterKeyword. Вот обновленный on_data методы

def on_data(self, data): 
datajson = json.loads(data) 
for word in filterKeywords: 
    if datajson.get('text') and word in datajson['text']: 
     collection = db[word] 
     collection.insert(datajson) 
     print('Tweet found filtered by ' + word)