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したらいいですか？ |
