ターミナルを介してphirehoseからサンプル スクリプトを実行し、テスト ツイートのライブ/アクティブな ptint_r を確認しました。ゲットー キュー ファイルをロードしたところ、ログが実行され、見事な成功を収めました。しかし、データがどこに行ったのかを見つけることができないようです。実際に書き込んでいるファイルは何ですか?2 つのサンプル ファイルは、スクリプトが実行されている場所に関連するディレクトリであると信じさせますが、何も表示されませghetto-queue-collect.php
んghetto-queue-consume.php
。/tmp
助言がありますか?
ログからの行の一部を次に示します
[03-Mar-2014 02:44:43 America/New_York] Phirehose: Opening new active status stream: /tmp/.phirehose-ghettoqueue.current
[03-Mar-2014 02:45:12 America/New_York] Phirehose: Successfully rotated active stream to queue file: /tmp/phirehose-ghettoqueue.20140303-024512.queue
- - - と - - -
[03-Mar-2014 03:41:58 America/New_York] Processing file: /tmp/phirehose-ghettoqueue.20140303-024102.queue
[03-Mar-2014 03:41:59 America/New_York] Successfully processed 1 tweets from /tmp/phirehose-ghettoqueue.20140303-024102.queue - deleting.
-- 問題のコードの一部だと思います --
/**
* Subclass specific constants
*/
const QUEUE_FILE_PREFIX = 'phirehose-ghettoqueue';
const QUEUE_FILE_ACTIVE = '.phirehose-ghettoqueue.current';
public function __construct($username, $password, $queueDir = '/tmp', $rotateInterval = 10)
// Set subclass parameters
$this->queueDir = $queueDir;
// Construct stream file name, log and open
$this->streamFile = $this->queueDir . '/' . self::QUEUE_FILE_ACTIVE;
$this->log('Opening new active status stream: ' . $this->streamFile);
$this->statusStream = fopen($this->streamFile, 'a'); // Append if present (crash recovery)