Node
1var Twitter = require('twitter'); 2var mysql = require('mysql'); 3 4var connection = mysql.createConnection({ 5 host: "localhost", 6 user: "root", 7 database: "db" 8}); 9 10var client = new Twitter({ 11 consumer_key: key, 12 consumer_secret: secret, 13 access_token_key:key, 14 access_token_secret: secret 15}); 16var maxId; 17function getTweet() { 18 return new Promise(function(resolve,reject) { 19 connection.query('SELECT MIN(tweet_id) FROM Tweets;',function(error,result,fields){ 20 maxId = result[0]["MIN(tweet_id)"]; 21 if (result) resolve(maxId); 22 if (error) reject(error); 23 }); 24 }); 25} 26getTweet().then(function(maxId) { 27 var params = {q: 'user',count:5,max_id_str:maxId}; 28 client.get('search/tweets', params, function(error, tweets, response) { 29 30 if(!error){ 31 var tweets_length = tweets["statuses"].length; 32 for(var i = 1;i < tweets_length;i++){ 33 tweet_id = tweets["statuses"][i]["id_str"]; 34 screen_name = tweets["statuses"][i]["user"]["screen_name"]; 35 text = tweets["statuses"][i]["text"]; 36 //var url = 'https://twitter.com/' + screen_name + '/status/' + tweet_id; 37 if(screen_name === "user"){ 38 console.log("user発見"); 39 break; 40 }else{ 41 connection.query('INSERT INTO Tweets(`tweet_id`,`name`,`text`) VALUES(?,?,?)',[tweet_id,screen_name,text],function(error,results,fields){ 42connection.destory(); 43 if(error)console.log(error); 44 }); 45 } 46 } 47 48 } 49 }); 50}).catch(function(err){ 51 console.log(err); 52}); 53
Lambdaでこのプログラムを実行するためにはdestoryしないといけないのですがどうdestoryしたらいいのでしょうか?Lambdaではdestoryしないとtimeoutになります。
これだと1個目のInsertは可能なのですが、2個目はInsertできません。
This socket is closedとエラーが出ます。
どうdestoryしたらいいですか?
バッドをするには、ログインかつ
こちらの条件を満たす必要があります。