ผลต่างระหว่างรุ่นของ "วิธีเรียกใช้ทวิตเตอร์สตรีมมิ่ง API ด้วยไพธอน"
จาก Morange Wiki
| (ไม่แสดง 1 รุ่นระหว่างกลางโดยผู้ใช้คนเดียวกัน) | |||
| แถว 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 เพื่อรับ | + | # ลงทะเบียนแอปพลิเคชันใหม่ที่ https://apps.twitter.com เพื่อรับ key ที่จำเป็น |
| + | ## API key จะconsumer_token และ consumer_secret ที่เราสร้างขึ้น | ||
| + | ## ที่แถบ API Keys หรือ จัดการ key จะมีปุ่มสำหรับสร้าง accces key ซึ่งจะได้ Access token และ Access token secret ตามละดับ | ||
# เขียนโปรแกรม | # เขียนโปรแกรม | ||
| แถว 19: | แถว 21: | ||
from tweepy.streaming import StreamListener | from tweepy.streaming import StreamListener | ||
| − | #เปลี่ยนเป็น key | + | #เปลี่ยนเป็น key ที่ได้รับจากหน้าลงทำเบียน app |
| − | + | api_key = 'consumer_token' | |
| − | + | api_secret = 'consumer_secret' | |
| − | + | access_token = 'access_token' | |
| − | + | access_secret = 'access_token_secret' | |
class listener(StreamListener): | class listener(StreamListener): | ||
| แถว 34: | แถว 36: | ||
print status | print status | ||
| − | auth = OAuthHandler( | + | auth = OAuthHandler(api_key, api_secret) |
| − | auth.set_access_token( | + | auth.set_access_token(access_token, access_secret) |
twitterStream = Stream(auth, listener()) | twitterStream = Stream(auth, listener()) | ||
twitterStream.filter(track=["car"]) | twitterStream.filter(track=["car"]) | ||
| แถว 41: | แถว 43: | ||
|} | |} | ||
| − | จากนั้นก็ลองเรียกใช้ดู | + | จากนั้นก็ลองเรียกใช้ดู จะพบว่า มีข้อความของ tweet ในรูปแบบไหลมาไม่ขาดสาย ซึ่งเราสามารถจัดการต่อไปได้อีก |
| + | รายละเอียดการใช้งาน tweepy สามารถดูได้จากเอกสารการใช้งาน<ref>http://tweepy.readthedocs.org/en/v2.3.0/</ref> | ||
== อ้างอิง == | == อ้างอิง == | ||
| แถว 48: | แถว 51: | ||
== แหล่งที่มา == | == แหล่งที่มา == | ||
* [http://sentdex.com/sentiment-analysisbig-data-and-python-tutorials-algorithmic-trading/how-to-use-the-twitter-api-1-1-to-stream-tweets-in-python/ How to use the Twitter API 1.1 To Stream Tweets in Python] | * [http://sentdex.com/sentiment-analysisbig-data-and-python-tutorials-algorithmic-trading/how-to-use-the-twitter-api-1-1-to-stream-tweets-in-python/ How to use the Twitter API 1.1 To Stream Tweets in Python] | ||
| + | |||
| + | [[Category:การพัฒนาซอฟต์แวร์]] | ||
รุ่นแก้ไขปัจจุบันเมื่อ 11:30, 30 มิถุนายน 2557
ทวีตเตอร์ สตรีมมิ่ง API [1] เป็นส่วนเชื่อมต่อโปรแกรม (API) ที่ทำงานผ่านเว็บ ณ ปัจจุบัน เวอร์ชัน 1.1 ข้อต่างของสตรีมมิ่ง API กับ REST ธรรมดาคือ สตรีมมิ่งจะมีการเชื่อมต่อ HTTP อยู่ตลอด และส่งข้อมูลกับมาให้อย่างต่อเนื่อง ขณะที่ REST เมื่อรับส่งข้อมูลแล้วจะตัการเชื่อมต่อ และต้องเชื่อมต่อไปใหม่อีกครั้ง
สิ่งที่ต้องเตรียม
- ตัวแปลภาษาไพธอน [2] ตามระบบปฎิบัติการ
- ลงตัวช่วยติดตั้ง pip [3]
- พิมพ์คำสั่ง pip install tweepy
- ลงทะเบียนแอปพลิเคชันใหม่ที่ https://apps.twitter.com เพื่อรับ key ที่จำเป็น
- API key จะconsumer_token และ consumer_secret ที่เราสร้างขึ้น
- ที่แถบ API Keys หรือ จัดการ key จะมีปุ่มสำหรับสร้าง accces key ซึ่งจะได้ Access token และ Access token secret ตามละดับ
- เขียนโปรแกรม
from tweepy import Stream
from tweepy import OAuthHandler
from tweepy.streaming import StreamListener
#เปลี่ยนเป็น key ที่ได้รับจากหน้าลงทำเบียน app
api_key = 'consumer_token'
api_secret = 'consumer_secret'
access_token = 'access_token'
access_secret = 'access_token_secret'
class listener(StreamListener):
def on_data(self, data):
print data
return True
def on_error(self, status):
print status
auth = OAuthHandler(api_key, api_secret)
auth.set_access_token(access_token, access_secret)
twitterStream = Stream(auth, listener())
twitterStream.filter(track=["car"]) |
จากนั้นก็ลองเรียกใช้ดู จะพบว่า มีข้อความของ tweet ในรูปแบบไหลมาไม่ขาดสาย ซึ่งเราสามารถจัดการต่อไปได้อีก รายละเอียดการใช้งาน tweepy สามารถดูได้จากเอกสารการใช้งาน[4]
