使用 Twitter 流 API

Question

我需要使用实时推文样本。我有这段代码，但我无法通过调用正确的链接得到任何信息。当然，我输入了正确的用户名和密码，但仍然没有成功。请指教是因为 Twitter 最近更改了 API。抱歉，如果这个问题很基本，我对此很陌生。提前致谢

<?php
//datacollector.php
$fp =
fopen("http://username:[email protected]/spritzer.json
while($data = fgets($fp))
{
    $time = date("YmdH");
    if ($newTime!=$time)
    {
        @fclose($fp2);
        $fp2 = fopen("{$time}.txt","a");
    }
    fputs($fp2,$data);
    $newTime = $time;
}
?>

Answer 1

DWRoelands 发布的有关弃用的内容是正确的，但这实际上不是您的问题 - 问题是 Twitter 已弃用 spritzer.json。您应该使用 /1/statuses/sample.json 来获取消防软管。这是一个有效的命令行示例：

curl http://stream.twitter.com/1/statuses/sample.json -uusername:password

如果您希望在生产中长期使用此代码，我当然会考虑实现 OAuth，但由于 Twitter 甚至还没有宣布关闭基本身份验证的时间表，因此没有如果你只是在闲逛，那就赶紧吧。当然，他们明天可以在没有任何警告的情况下将其关闭。

这是一些有效的 PHP 代码，只需将 username:password 替换为实际凭据：

<?php
//datacollector.php
$fp = fopen("http://username:[email protected]/1/statuses/sample.json", "r");
while($data = fgets($fp)) {
    $time = date("YmdH");
    if ($newTime!=$time) {
        @fclose($fp2);
        $fp2 = fopen("{$time}.txt","a");
    }
    fputs($fp2,$data);
    $newTime = $time;
}
?>

Answer 2

如果您需要一个应用程序，您可以使用 Twitter C# API ：Tweetinvi 使用 C# 轻松开发

该 API 提供了一个 Stream 类这将允许您使用委托函数检索流的信息。

以下是示例提供的示例：

private static void streaming_example(Token token)
    {
        // Creating a Delegate to use processTweet function to analyze each Tweet coming from the stream
        Stream.ProcessTweetDelegate produceTweetDelegate = new Stream.ProcessTweetDelegate(processTweet);
        // Creating the stream and specifying the delegate
        Stream myStream = new Stream(produceTweetDelegate);
        // Starting the stream by specifying credentials thanks to the Token
        myStream.StartStream(token);
    }

实施起来既简单又快速。

我是该项目的开发人员之一。

Answer 3

流 API 文档表明您需要使用 OAuth 进行验证才能访问用户流。请参阅：Twitter：流 API 概念

该页面还表明基本身份验证将被弃用，所以我认为您需要调整代码以使用 OAuth。

Answer 4

从此处下载 lib 文件夹。将它们放入与以下代码相同的文件夹中。修改 Api 键并更改您要跟踪的关键字。如果您要在浏览器中执行它，请稍等一下。

 <?php
   /***************libraries*********************/
    require_once('../lib/Phirehose.php');
    require_once('../lib/OauthPhirehose.php');
   /*********Escape from Execution Time***********/
   set_time_limit(0);
    class FilterTrackConsumer extends OauthPhirehose
    {
      public function enqueueStatus($status)
      {
        $data = json_decode($status, true);

        if (is_array($data) && isset($data['user']['screen_name'])) {
          print $data['text'];
        }
      }
    }
 /*************************API KEYS*******************************/
    define('TWITTER_CONSUMER_KEY', 'api_key');
    define('TWITTER_CONSUMER_SECRET','api_secret');


    define('OAUTH_TOKEN','token');
    define('OAUTH_SECRET','token secret');?>

    // Start streaming
    $sc = new FilterTrackConsumer(OAUTH_TOKEN, OAUTH_SECRET, Phirehose::METHOD_FILTER);
    $sc->setTrack(array('#keyword'));
    $sc->consume();
  ?>