使用Anaconda开发Golang Twitter 1.1 API客户端

Anaconda是一个流行的Golang库，用于与Twitter 1.1 API交互。下面我将介绍如何使用Anaconda开发Twitter客户端。

安装Anaconda

首先安装Anaconda库：

go get github.com/ChimeraCoder/anaconda

基本设置

使用前需要从Twitter开发者平台获取API密钥：

package main

import (
	"github.com/ChimeraCoder/anaconda"
	"net/url"
)

func main() {
	// 设置Twitter API密钥
	anaconda.SetConsumerKey("YOUR_CONSUMER_KEY")
	anaconda.SetConsumerSecret("YOUR_CONSUMER_SECRET")
	
	// 创建API客户端实例
	api := anaconda.NewTwitterApi("ACCESS_TOKEN", "ACCESS_TOKEN_SECRET")
}

常用功能示例

1. 发送推文

func postTweet(api *anaconda.TwitterApi, text string) {
	tweet, err := api.PostTweet(text, nil)
	if err != nil {
		panic(err)
	}
	
	fmt.Printf("Tweet posted: %s\n", tweet.Text)
}

2. 获取用户时间线

func getUserTimeline(api *anaconda.TwitterApi, screenName string) {
	v := url.Values{}
	v.Set("screen_name", screenName)
	v.Set("count", "10") // 获取10条推文
	
	tweets, err := api.GetUserTimeline(v)
	if err != nil {
		panic(err)
	}
	
	for _, tweet := range tweets {
		fmt.Printf("%s: %s\n", tweet.User.ScreenName, tweet.Text)
	}
}

3. 搜索推文

func searchTweets(api *anaconda.TwitterApi, query string) {
	v := url.Values{}
	v.Set("q", query)
	v.Set("count", "15")
	
	searchResult, err := api.GetSearch(query, v)
	if err != nil {
		panic(err)
	}
	
	for _, tweet := range searchResult.Statuses {
		fmt.Printf("%s: %s\n", tweet.User.ScreenName, tweet.Text)
	}
}

4. 流式API (实时获取推文)

func streamTweets(api *anaconda.TwitterApi, trackWords []string) {
	v := url.Values{}
	v.Set("track", strings.Join(trackWords, ","))
	
	s := api.PublicStreamFilter(v)
	
	for tweet := range s.C {
		switch t := tweet.(type) {
		case anaconda.Tweet:
			fmt.Printf("%s: %s\n", t.User.ScreenName, t.Text)
		case anaconda.EventTweet:
			// 处理事件
		}
	}
}

高级功能

1. 分页处理

func getFollowers(api *anaconda.TwitterApi, screenName string) {
	v := url.Values{}
	v.Set("screen_name", screenName)
	v.Set("count", "200") // 每页最大200
	
	cursor := "-1" // 初始游标
	for cursor != "0" {
		v.Set("cursor", cursor)
		result, err := api.GetFollowersList(v)
		if err != nil {
			panic(err)
		}
		
		for _, user := range result.Users {
			fmt.Println(user.ScreenName)
		}
		
		cursor = result.Next_cursor_str
	}
}

2. 上传媒体文件

func tweetWithImage(api *anaconda.TwitterApi, text string, imagePath string) {
	// 上传图片
	file, err := os.Open(imagePath)
	if err != nil {
		panic(err)
	}
	defer file.Close()
	
	media, err := api.UploadMedia(file)
	if err != nil {
		panic(err)
	}
	
	// 发送带图片的推文
	v := url.Values{}
	v.Set("media_ids", media.MediaIDString)
	
	_, err = api.PostTweet(text, v)
	if err != nil {
		panic(err)
	}
}

错误处理

Twitter API有严格的速率限制，需要妥善处理：

func safeTwitterCall(api *anaconda.TwitterApi, call func() error) {
	err := call()
	if err != nil {
		if rateLimitErr, ok := err.(*anaconda.ApiError); ok {
			if rateLimitErr.StatusCode == 429 {
				// 达到速率限制
				fmt.Println("Rate limit exceeded. Waiting...")
				time.Sleep(15 * time.Minute) // 等待15分钟
				return
			}
		}
		panic(err)
	}
}

完整示例

package main

import (
	"fmt"
	"github.com/ChimeraCoder/anaconda"
	"net/url"
	"os"
)

func main() {
	anaconda.SetConsumerKey(os.Getenv("TWITTER_CONSUMER_KEY"))
	anaconda.SetConsumerSecret(os.Getenv("TWITTER_CONSUMER_SECRET"))
	api := anaconda.NewTwitterApi(
		os.Getenv("TWITTER_ACCESS_TOKEN"),
		os.Getenv("TWITTER_ACCESS_TOKEN_SECRET"),
	)
	
	// 发送测试推文
	tweet, err := api.PostTweet("Testing Anaconda Twitter API client", nil)
	if err != nil {
		panic(err)
	}
	fmt.Printf("Posted tweet: %s\n", tweet.Text)
	
	// 获取时间线
	v := url.Values{}
	v.Set("count", "5")
	timeline, err := api.GetHomeTimeline(v)
	if err != nil {
		panic(err)
	}
	
	fmt.Println("\nHome timeline:")
	for _, t := range timeline {
		fmt.Printf("%s: %s\n", t.User.ScreenName, t.Text)
	}
}

最佳实践

1. 环境变量存储密钥：不要将API密钥硬编码在代码中
2. 错误处理：Twitter API有严格的速率限制，需要妥善处理
3. 并发控制：避免短时间内发送过多请求
4. 日志记录：记录API调用情况以便调试
5. 测试账号：开发时使用测试账号，避免影响主账号

Anaconda提供了对Twitter API的全面覆盖，以上示例展示了基本用法，更多功能可以参考官方文档和Twitter API文档。