1
ライブラリとforeverを使用して簡単なtwitterbotを実行しようとしています。ボットは本質的に別のツイッターアカウントを監視し、変更を加えてそのツイートをコピーします。ノードは永遠にプログラムが実行されていると言われますが、証拠は示唆していません
私はストリーミングAPIから受信したツイートをロギングしており、エラーも記録しています。
しかし、ロボットはエラーをログに記録しないで、しばしば動作を停止しますが、forever listはまだプログラムが実行中であると表示します。まず
info: Forever processes running
data: uid command script forever pid id logfile uptime
data: [0] QOmt /usr/bin/nodejs bot.js 13642 13649 /home/ubuntu/.forever/QOmt.log 0:5:25:34.733
、私はこれはTwitterのストリーミングAPIに問題があると考えていた - ログファイルは、Twitterからの新しいメッセージを記録するために停止したとして、すなわち、その情報は、「パイプダウン」送られて停止していましたストリーミングAPI。
ボットが実際に実行されていることを確認するために、毎分ログするheartbeatを作成しました。
// Heartbeat to make sure the process is still running
setInterval(function() {
console.logWithDate('Program heartbeat');
}, 60*1000);
ボットが機能しなくなると、ハートビートもロギングを停止します。まだforeverは、ボットが実行中であるとしています。
ご協力いただければ幸いです。それが役に立つ場合は、私のボットの完全なコードを以下に投稿します。
#!/usr/bin/env node
"use strict"
const fs = require('fs');
const util = require('util');
const Twit = require('twit');
// Logging
const error_log_file = fs.createWriteStream(__dirname + '/debug.log', {flags : 'a'});
const log_stdout = process.stdout;
console.error = function(d) {
error_log_file.write(util.format("\n%s> %s", new Date(), d) + '\n');
log_stdout.write(util.format("\n%s> %s", new Date(), d) + '\n');
};
console.logWithDate = function(d) {
log_stdout.write(util.format("\n%s> %s", new Date(), d) + '\n');
}
// Heartbeat to make sure the process is still running
setInterval(function() {
console.logWithDate('Program heartbeat');
}, 60*1000);
// Read in twitter secrets file
const twitter_secrets = JSON.parse(fs.readFileSync("twitter_secrets.json"));
// Connect to twitter
const client = new Twit({
consumer_key: twitter_secrets.TWITTER_CONSUMER_KEY,
consumer_secret: twitter_secrets.TWITTER_CONSUMER_SECRET,
access_token: twitter_secrets.TWITTER_ACCESS_TOKEN_KEY,
access_token_secret: twitter_secrets.TWITTER_ACCESS_TOKEN_SECRET,
timeouts_ms: 60*1000
});
// Main
const stream = client.stream('statuses/filter', {follow: 87818409});
stream.on('tweet', function(event) {
if (event.user.id === 87818409) {
console.logWithDate("Guardian tweet: " + event.text)
client.post(
'statuses/update',
{status: misspellRandomWords(event.text)},
function(error, tweet, response) {
if (error) {
console.error(error);
} else {
console.logWithDate("Bot tweet: " + tweet.text); // Tweet body.
//console.log(response); // Raw response object.
}
}
);
} else {
console.logWithDate("Guardian-related tweet: " + event.text)
}
});
// Log various types of messages for debugging
stream.on('limit', function(error) {
console.error(error);
});
stream.on('disconnect', function(error) {
console.error(error);
});
stream.on('error', function(error) {
console.error(error);
});
stream.on('connect', function (conn) {
console.logWithDate('connecting')
})
stream.on('reconnect', function (reconn, res, interval) {
console.logWithDate('reconnecting. statusCode:', res.statusCode)
})
/* Helper functions */
function swapRandomLetters(word) {
const limit = word.length;
const iFirstLetter = Math.floor(Math.random() * limit);
var iSecondLetter = Math.floor(Math.random() * limit);
while (iFirstLetter === iSecondLetter) {
iSecondLetter = Math.floor(Math.random() * limit);
}
let letters = word.split("");
letters[iFirstLetter] = word[iSecondLetter];
letters[iSecondLetter] = word[iFirstLetter];
return letters.join("");
}
function isLink(word) {
// Very crude URL check
return word.substring(0,4) === "http";
}
function misspellRandomWords(sentence) {
let words = sentence.split(" ");
const limit = words.length;
// Choose a first word, filtering out urls
var iFirstWord = Math.floor(Math.random() * limit);
while (isLink(words[iFirstWord]) || words[iFirstWord][0] === "@") {
iFirstWord = Math.floor(Math.random() * limit);
}
// Choose second misspelled word, and make sure it isn't the first or an URL
var iSecondWord = Math.floor(Math.random() * limit);
while (isLink(words[iSecondWord]) ||
iSecondWord === iFirstWord ||
words[iSecondWord][0] === "@") {
iSecondWord = Math.floor(Math.random() * limit);
}
words[iFirstWord] = swapRandomLetters(words[iFirstWord]);
words[iSecondWord] = swapRandomLetters(words[iSecondWord]);
return words.join(" ");
}