質問編集履歴

1 質問を詳しく

adwadwadw

adwadwadw score 60

2016/11/19 06:47  投稿

Lambdaで実行するためにdestoryしたい
```Node
var Twitter = require('twitter');  
var mysql = require('mysql');
for(var i = 1;i < tweets_length;i++){
var connection = mysql.createConnection({
 host: "localhost",
 user: "root",
 database: "db"
});
var client = new Twitter({
 consumer_key: key,
 consumer_secret: secret,
 access_token_key:key,
 access_token_secret: secret
});
var maxId;
function getTweet() {
 return new Promise(function(resolve,reject) {
   connection.query('SELECT MIN(tweet_id) FROM Tweets;',function(error,result,fields){
     maxId = result[0]["MIN(tweet_id)"];
     if (result) resolve(maxId);
     if (error) reject(error);
   });
 });
}
getTweet().then(function(maxId) {
 var params = {q: 'user',count:5,max_id_str:maxId};
 client.get('search/tweets', params, function(error, tweets, response) {
   if(!error){
     var tweets_length = tweets["statuses"].length;
     for(var i = 1;i < tweets_length;i++){
       tweet_id = tweets["statuses"][i]["id_str"];
       screen_name = tweets["statuses"][i]["user"]["screen_name"];
       text = tweets["statuses"][i]["text"];
 
       //var url = 'https://twitter.com/' + screen_name + '/status/' + tweet_id;
       if(screen_name === "user"){
         console.log("user発見");
         break;
       }else{
         connection.query('INSERT INTO Tweets(`tweet_id`,`name`,`text`) VALUES(?,?,?)',[tweet_id,screen_name,text],function(error,results,fields){
connection.destory();  
           if(error)console.log(error);
         });
       }
     }
 
   }  
 });  
}).catch(function(err){  
 console.log(err);  
});  
 
```
Lambdaでこのプログラムを実行するためにはdestoryしないといけないのですがどうdestoryしたらいいのでしょうか?Lambdaではdestoryしないとtimeoutになります。
Lambdaでこのプログラムを実行するためにはdestoryしないといけないのですがどうdestoryしたらいいのでしょうか?Lambdaではdestoryしないとtimeoutになります。
これだと1個目のInsertは可能なのですが、2個目はInsertできません。
This socket is closedとエラーが出ます。
どうdestoryしたらいいですか?
  • MySQL

    9231 questions

    MySQL(マイエスキューエル)は、TCX DataKonsultAB社などが開発するRDBMS(リレーショナルデータベースの管理システム)です。世界で最も人気の高いシステムで、オープンソースで開発されています。MySQLデータベースサーバは、高速性と信頼性があり、Linux、UNIX、Windowsなどの複数のプラットフォームで動作することができます。

  • Node.js

    3296 questions

    Node.jsとはGoogleのV8 JavaScriptエンジンを使用しているサーバーサイドのイベント駆動型プログラムです。

思考するエンジニアのためのQ&Aサイト「teratail」について詳しく知る