0

我正在利用 Twitter firehose 来存储一些基于某些设置过滤器的推文，以用于分析目的。

我编写了一个 PHP 脚本，它打开与 Twitter 流的连接，并在（！eof）时保持打开状态......所以这基本上无限期地保持打开状态。

但是，我将其设置为在 5 秒后停止。我想使用 AJAX 每 5.5 秒调用一次此脚本（偏移以确保它们不会发生冲突），然后在成功时重新循环等...

问题是我的函数似乎没有收到“成功”信号。这里发生了什么？

以下是我的代码的相关部分：

$(function() {
    makeRequest();
});

function makeRequest(){
    console.log("Getting tweets...");
    $.ajax({
        url: "./php/store_tweets.php",
        success: function(){
            console.log("Success!");
            makeRequest();
        }
    });
}

剧本：

<?php
$start      = time();
$expAddress = "HOSTNAME";
$expUser    = "USERNAME";
$expPwd     = "PASSWORD";
$database   = "DBNAME";

$opts = array(
    'http' => array(
        'method' => "POST",
        'content' => 'keywords,go,here'
    )
);

// Open connection to stream
$db = mysql_connect($expAddress, $expUser, $expPwd);
mysql_select_db($database, $db);

$context  = stream_context_create($opts);
$instream = fopen('https://USERNAME:PASSWORD@stream.twitter.com/1/statuses/filter.json', 'r', false, $context);
while (!feof($instream)) {

    if (time() - $start > 5) { // break after 5 seconds
        break;
    }


    if (!($line = stream_get_line($instream, 100000, "\n"))) {
        continue;
    } else {
        $tweet = json_decode($line);

        // Clean before storing             

        // LOTS OF VARIABLES FOR BELOW...REMOVED FOR READABILITY

        // Send to database
        $ok = mysql_query("INSERT INTO tweets 
                    (created_at, from_user, from_user_id, latitude, longitude, tweet_id, language_code, 
                            place_name, profile_img_url, source, text, retweet_count, followers_count,
                            friends_count, listed_count, favorites_count) 
                    VALUES 
                    (NOW(), '$from_user', '$from_user_id', '$latitude', '$longitude', '$tweet_id', '$language_code', 
                            '$place_name', '$profile_img_url', '$source', '$text', '$retweet_count', '$followers_count',
                            '$friends_count', '$listed_count', '$favorites_count')");

        if (!$ok) {
            echo "Mysql Error: " . mysql_error();
        }

        flush();
    }
}
?>
4

1 回答 1

-1

您应该尝试 javascript 函数setInterval。

<script type="text/javascript">
var myVar=setInterval(function(){makeRequest()},5000);
function myStopFunction()
{
    clearInterval(myVar);
}
</script>
于 2013-03-06T17:39:08.030 回答