Instagram 实时 API 次重复请求

Instagram Real-time API duplicate requests

我有一个问题,当我创建实时订阅时,我收到来自不同 Instagram IP 地址的重复通知。我已对其进行设置,以便在收到通知时使用 min_tag_id 设置发送最新更新请求。我将其存储在我的数据库中以用于下一个请求。我并不总是得到重复项,但当我这样做时,关于通知的所有内容都是相同的(时间、对象、changed_aspect),除了我可以看出它们与我的调试输出不同,后者列出了两个几乎相同的请求。 .. 唯一不同的信息是不同的 IP 地址和 REQUEST_TIME_FLOAT 相差大约 1/10 秒。它们甚至具有相同的 HTTP_X_HUB_SIGNATURE 值。

我的通用算法是:

process_subscription_update($data){
    # get old min_id
    $min_tag_id = mysqli_fetch_object(mysqli_query($dbconnecti,sprintf("SELECT instagram_min_id+0 as instaid FROM xxxx WHERE xxxx=%d",$_GET['xxxx'])));
    $min_id = $min_tag_id->instaid;
    # make api call
    $ch = curl_init();
    curl_setopt($ch,CURLOPT_URL, 'https://api.instagram.com/v1/tags/'.$_GET['tag'].'/media/recent?client_id=xxxx&min_tag_id='.$min_id.($min_id==0?'&count=1':''));
    curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
    $result = curl_exec($ch);
    curl_close($ch);
    $i = json_decode($result);
    if ($min_id == $i->pagination->min_tag_id) { exit; }
    # write new min_id to db
    record_min_id($i->pagination->min_tag_id);
    $data2 = $i->data;
    foreach($data2 as $d) {
        process_instagram($d);
    }
    // debugging output: ****************
    $file = file_get_contents($_SERVER['DOCUMENT_ROOT'].'instagram/updates.txt');
    $foo = "\n";
    foreach($_SERVER as $key_name => $key_value) {
        $foo .= $key_name . " = " . $key_value . "\n";
    }
    $fulldata = $file . "\n\n\n" .  $result . "\n min_id = " . $min_id . $foo;
    $fulldata .= "\nTIME:".$data[0]->time;
    $fulldata .= "\nOBJECT:".$data[0]->object;
    $fulldata .= "\nCHANGED_ASPECT:".$data[0]->changed_aspect;
    file_put_contents($_SERVER['DOCUMENT_ROOT'].'instagram/updates.txt', $fulldata);    
    // end debugging output *************

}

我想避免在 process_instagram 函数中检查 instagram 消息 ID 是否已存在于我的数据库中,并且重复项仅相隔 1/10 秒,我不知道如果那会起作用的话。

还有其他人遇到过这个问题and/or有解决方案吗?

我解决了这个问题。对于收到重复的通知,我认为我无能为力。因此,在将 Instagram 写入我的数据库时,我有一个 Instagram id 字段,并在该字段上设置了唯一约束。在执行 mysqli INSERT 后,我检查是否 errno = 1062,如果是,我退出。

mysqli_query($dbconnecti,"INSERT INTO xxx (foo, etc, instagram_id ...")
if ($dbconnecti->errno==1062) { exit; }
...
// more script runs here if we don't have a duplicate.