質問編集履歴
1
質問を詳しく
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -1,8 +1,68 @@
|
|
|
1
1
|
```Node
|
|
2
|
+
|
|
3
|
+
var Twitter = require('twitter');
|
|
2
4
|
|
|
3
5
|
var mysql = require('mysql');
|
|
4
6
|
|
|
7
|
+
|
|
8
|
+
|
|
9
|
+
var connection = mysql.createConnection({
|
|
10
|
+
|
|
11
|
+
host: "localhost",
|
|
12
|
+
|
|
13
|
+
user: "root",
|
|
14
|
+
|
|
15
|
+
database: "db"
|
|
16
|
+
|
|
17
|
+
});
|
|
18
|
+
|
|
19
|
+
|
|
20
|
+
|
|
21
|
+
var client = new Twitter({
|
|
22
|
+
|
|
23
|
+
consumer_key: key,
|
|
24
|
+
|
|
25
|
+
consumer_secret: secret,
|
|
26
|
+
|
|
27
|
+
access_token_key:key,
|
|
28
|
+
|
|
29
|
+
access_token_secret: secret
|
|
30
|
+
|
|
31
|
+
});
|
|
32
|
+
|
|
33
|
+
var maxId;
|
|
34
|
+
|
|
35
|
+
function getTweet() {
|
|
36
|
+
|
|
37
|
+
return new Promise(function(resolve,reject) {
|
|
38
|
+
|
|
39
|
+
connection.query('SELECT MIN(tweet_id) FROM Tweets;',function(error,result,fields){
|
|
40
|
+
|
|
41
|
+
maxId = result[0]["MIN(tweet_id)"];
|
|
42
|
+
|
|
43
|
+
if (result) resolve(maxId);
|
|
44
|
+
|
|
45
|
+
if (error) reject(error);
|
|
46
|
+
|
|
47
|
+
});
|
|
48
|
+
|
|
49
|
+
});
|
|
50
|
+
|
|
51
|
+
}
|
|
52
|
+
|
|
53
|
+
getTweet().then(function(maxId) {
|
|
54
|
+
|
|
55
|
+
var params = {q: 'user',count:5,max_id_str:maxId};
|
|
56
|
+
|
|
57
|
+
client.get('search/tweets', params, function(error, tweets, response) {
|
|
58
|
+
|
|
59
|
+
|
|
60
|
+
|
|
61
|
+
if(!error){
|
|
62
|
+
|
|
63
|
+
var tweets_length = tweets["statuses"].length;
|
|
64
|
+
|
|
5
|
-
for(var i = 1;i < tweets_length;i++){
|
|
65
|
+
for(var i = 1;i < tweets_length;i++){
|
|
6
66
|
|
|
7
67
|
tweet_id = tweets["statuses"][i]["id_str"];
|
|
8
68
|
|
|
@@ -10,7 +70,7 @@
|
|
|
10
70
|
|
|
11
71
|
text = tweets["statuses"][i]["text"];
|
|
12
72
|
|
|
13
|
-
|
|
73
|
+
//var url = 'https://twitter.com/' + screen_name + '/status/' + tweet_id;
|
|
14
74
|
|
|
15
75
|
if(screen_name === "user"){
|
|
16
76
|
|
|
@@ -22,6 +82,8 @@
|
|
|
22
82
|
|
|
23
83
|
connection.query('INSERT INTO Tweets(`tweet_id`,`name`,`text`) VALUES(?,?,?)',[tweet_id,screen_name,text],function(error,results,fields){
|
|
24
84
|
|
|
85
|
+
connection.destory();
|
|
86
|
+
|
|
25
87
|
if(error)console.log(error);
|
|
26
88
|
|
|
27
89
|
});
|
|
@@ -30,8 +92,28 @@
|
|
|
30
92
|
|
|
31
93
|
}
|
|
32
94
|
|
|
95
|
+
|
|
96
|
+
|
|
97
|
+
}
|
|
98
|
+
|
|
99
|
+
});
|
|
100
|
+
|
|
101
|
+
}).catch(function(err){
|
|
102
|
+
|
|
103
|
+
console.log(err);
|
|
104
|
+
|
|
105
|
+
});
|
|
106
|
+
|
|
107
|
+
|
|
108
|
+
|
|
33
109
|
```
|
|
34
110
|
|
|
35
111
|
|
|
36
112
|
|
|
37
113
|
Lambdaでこのプログラムを実行するためにはdestoryしないといけないのですがどうdestoryしたらいいのでしょうか？Lambdaではdestoryしないとtimeoutになります。
|
|
114
|
+
|
|
115
|
+
これだと1個目のInsertは可能なのですが、2個目はInsertできません。
|
|
116
|
+
|
|
117
|
+
This socket is closedとエラーが出ます。
|
|
118
|
+
|
|
119
|
+
どうdestoryしたらいいですか？
|