ผลต่างระหว่างรุ่นของ "วิธีเรียกใช้ทวิตเตอร์สตรีมมิ่ง API ด้วยไพธอน"

จาก Morange Wiki
(หน้าที่ถูกสร้างด้วย ' ทวีตเตอร์ สตรีมมิ่ง API <ref>https://dev.twitter.com/docs/api/streaming</ref> เป็นส่...')
 
แถว 8: แถว 8:
 
# ลงตัวช่วยติดตั้ง pip <ref>https://pip.pypa.io/en/latest/installing.html</ref>
 
# ลงตัวช่วยติดตั้ง pip <ref>https://pip.pypa.io/en/latest/installing.html</ref>
 
# พิมพ์คำสั่ง pip install tweepy
 
# พิมพ์คำสั่ง pip install tweepy
# จัดโปรแกรม
+
# ลงทะเบียนแอปพลิเคชันใหม่ที่ https://apps.twitter.com เพื่อรับ consumer_token และ consumer_secret ที่เราสร้างขึ้น
 +
# เขียนโปรแกรม
  
 
{| class="wikitable"
 
{| class="wikitable"
แถว 19: แถว 20:
  
 
#เปลี่ยนเป็น key ที่ถูกต้อง
 
#เปลี่ยนเป็น key ที่ถูกต้อง
ckey = 'xWSJ00HHasfaHP8YDvmhCmTdqA'   
+
ckey = 'consumer_token'   
csecret = 'eF3oTgafZUs7ZCTHXyaI7g2krrpvf2LaWf6sSIlQaww'
+
csecret = 'consumer_secret'
atoken = '1401204486-k0fGslaW87Op0MsPYYi2vcstRj0s1HNhVyDSKAB44P'
+
atoken = 'access_token'
asecret = 'Pi60VAcdaby409frT61gvllsYixNhZassDimklSb9Y3F8'
+
asecret = 'access_secret'
  
 
class listener(StreamListener):
 
class listener(StreamListener):

รุ่นแก้ไขเมื่อ 10:41, 29 พฤษภาคม 2557

ทวีตเตอร์ สตรีมมิ่ง API [1] เป็นส่วนเชื่อมต่อโปรแกรม (API) ที่ทำงานผ่านเว็บ ณ ปัจจุบัน เวอร์ชัน 1.1 ข้อต่างของสตรีมมิ่ง API กับ REST ธรรมดาคือ สตรีมมิ่งจะมีการเชื่อมต่อ HTTP อยู่ตลอด และส่งข้อมูลกับมาให้อย่างต่อเนื่อง ขณะที่ REST เมื่อรับส่งข้อมูลแล้วจะตัการเชื่อมต่อ และต้องเชื่อมต่อไปใหม่อีกครั้ง

สิ่งที่ต้องเตรียม

  1. ตัวแปลภาษาไพธอน [2] ตามระบบปฎิบัติการ
  2. ลงตัวช่วยติดตั้ง pip [3]
  3. พิมพ์คำสั่ง pip install tweepy
  4. ลงทะเบียนแอปพลิเคชันใหม่ที่ https://apps.twitter.com เพื่อรับ consumer_token และ consumer_secret ที่เราสร้างขึ้น
  5. เขียนโปรแกรม
from tweepy import Stream
from tweepy import OAuthHandler
from tweepy.streaming import StreamListener

#เปลี่ยนเป็น key ที่ถูกต้อง
ckey = 'consumer_token'  
csecret = 'consumer_secret'
atoken = 'access_token'
asecret = 'access_secret'

class listener(StreamListener):

    def on_data(self, data):
        print data
        return True

    def on_error(self, status):
        print status

auth = OAuthHandler(ckey, csecret)
auth.set_access_token(atoken, asecret)
twitterStream = Stream(auth, listener())
twitterStream.filter(track=["car"])

จากนั้นก็ลองเรียกใช้ดู

อ้างอิง

แหล่งที่มา