Pythonグローバル名 'urls'が定義されていません。

Question

urlsが正しく定義されていますが、私は"global name 'urls' is not defined"を取得し続け、URLデータはMYSQLにinsertedではありません。どこの提案？私はここで間違いをしているのですか？

# ! /usr/bin/python 

# Description : This script can collect the URLs from Tweets and Records them into research MYSQL DB. 

from __future__ import print_function 
import tweepy 
import json 
import MySQLdb 
from dateutil import parser 

WORDS = ['security'] 

# CREDENTAILS 
CONSUMER_KEY = "" 
CONSUMER_SECRET = "" 
ACCESS_TOKEN = "" 
ACCESS_TOKEN_SECRET = "" 

HOST = "192.168.150.94" 
USER = "root" 
PASSWD = "blah" 
DATABASE = "tweets" 


def store_data(tweet_url): 
    db = MySQLdb.connect(host=HOST, user=USER, passwd=PASSWD, db=DATABASE, 
         charset="utf8") 
    cursor = db.cursor() 
    insert_query = "INSERT INTO tweet_url (urls) VALUES (%s)" 
    cursor.execute(insert_query, (urls)) 
    db.commit() 
    cursor.close() 
    db.close() 
    return 


class StreamListener(tweepy.StreamListener): 
    def on_connect(self): 
     print("We are now connected to the streaming API.") 

    def on_error(self, status_code): 
     print('An Error has occured: ' + repr(status_code)) 
     return False 

    def on_data(self, data): 
     try: 
      datajson = json.loads(data) 
      web_url = datajson['entities']['urls'] 
      print(web_url) 
      for i in web_url: 
       web_urls = i['expanded_url'] 
       urls = web_urls 
      print(urls) 
     store_data(urls) 

    except Exception as e: 
    print(e) 


auth = tweepy.OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET) 
auth.set_access_token(ACCESS_TOKEN, ACCESS_TOKEN_SECRET) 
listener = StreamListener(api=tweepy.API(wait_on_rate_limit=True)) 
streamer = tweepy.Stream(auth=auth, listener=listener) 
print("Tracking: " + str(WORDS)) 
streamer.filter(track=WORDS) 

Answer 1

あなたはちょうどあなたがデータを保存する方法が不明のまま

def store_data(tweet_url): 
    db = MySQLdb.connect(host=HOST, user=USER, passwd=PASSWD, db=DATABASE, 
         charset="utf8") 
    cursor = db.cursor() 
    insert_query = "INSERT INTO tweet_url (urls) VALUES (%s)" 
    cursor.execute(insert_query, (tweet_url)) 

tweet_url

に機能 store_dataのパラメータ urlsの名前を変更する必要があります。あなたはループの後 store_dataを呼び出した場合、あなたがより良いリスト内の各値を格納する必要があり、最後の値を格納しています：

def on_data(self, data): 
    try: 
     datajson = json.loads(data) 
     web_url = datajson['entities']['urls'] 
     print(web_url) 
     urls = [] 
     for i in web_url: 
      urls.append((i['expanded_url'],)) 
      # stores a tuple to make it easy in the database insertion 
     print(urls) 
     store_data(urls) 
    except: 
     [...] 

この道をstore_data内部に別の少しの修正が必要になります。

あなたのインサイド

def store_data(urls): 
    db = MySQLdb.connect(host=HOST, user=USER, passwd=PASSWD, db=DATABASE, 
         charset="utf8") 
    cursor = db.cursor() 
    insert_query = "INSERT INTO tweet_url (urls) VALUES (%s)" 
    cursor.executemany(insert_query, urls) 
    db.commit() 
    cursor.close() 
    db.close() 
    return 

Answer 2

関数store_data()あなたは関数に渡すものがtweet_urlなので、定義されていないurlsを使用しています。

def store_data(urls): 
    # ... 

またはあなたの関数本体でtweet_urlへurlsを変更します：

# ... 
cursor.execute(insert_query, (tweet_url)) 
# ... 

そして、あなたが修正を確認してくださいあなたはurlsの代わりに、このようなtweet_urlにあなたの関数の引数を変更するか必要

内側のくぼみon_data()方法：

class StreamListener(tweepy.StreamListener): 
    # ... 

    def on_data(self, data): 
     try: 
      datajson = json.loads(data) 
      web_url = datajson['entities']['urls'] 
      print(web_url) 
      for i in web_url: 
       web_urls = i['expanded_url'] 
       urls = web_urls 
      print(urls) 
      store_data(urls) 
     except Exception as e: 
      print(e)