트위터 코드 추가

src/main/java/kr/co/swh/lecture/opensource/twitter/TwitterBasic.java

@@ -52,6 +52,15 @@ public class TwitterBasic {
 	    }else{
 	    	//	Quiz.
 	    	// 	따로 만들어야 함. 트위터는 한번에 100개씩 제한
+	    	//	Status 클래스의 객체 내 id값을 통해 가능
+//	    	query.setCount(100);    //트위터 API 에서 한번에 가져올 수 있는 양이 100개
+//	    	long lowestStatusId = Long.MAX_VALUE;
+//	    	List<Status> statuses = this.getTweetBlock(query);
+//			for (Status status : statuses) {
+//				lowestStatusId = Math.min(status.getId(), lowestStatusId);
+//				result.add(status);
+//			}
+//			query.setMaxId(lowestStatusId - 1);
 	    }
 		return tweetList;
 	}
@@ -92,5 +101,4 @@ public class TwitterBasic {
         	//	VO 클래스로 객체형태로 변환하여 다양하게 활용
         }
 	}
-
 }

src/main/java/kr/co/swh/lecture/opensource/twitter/TwitterStreaming.java

@@ -80,5 +80,4 @@ public class TwitterStreaming {
 	    // sample() method internally creates a thread which manipulates TwitterStream and calls these adequate listener methods continuously.
 	    twitterStream.sample("ko");
 	}
-
 }

src/main/python/kr/co/swh/lecture/opensource/twitter/twitter_crawler_basic.py

@@ -1,4 +1,5 @@
 # https://marcobonzanini.com/2015/03/02/mining-twitter-data-with-python-part-1/comment-page-1/
+# conda install -c conda-forge tweepy
 import tweepy
 from tweepy import OAuthHandler
 import json

src/main/python/kr/co/swh/lecture/opensource/twitter/twitter_crawler_streaming.py

@@ -1,5 +1,4 @@
 # https://imasoftwareengineer.tistory.com/97?category=791547
-# conda install -c conda-forge tweepy
 import tweepy
 from tweepy.streaming import StreamListener
 from tweepy import OAuthHandler
@@ -16,14 +15,10 @@ access_secret = 'xx'
 # 리스너 - 스트리밍 API로 부터 값이 들어오면 아래의 리스너가 실행된다.
 class Listener(StreamListener):
     def on_data(self, data):
-        try:
-            with open('sample.json', 'a', encoding='utf-8') as f:
-                json_data = json.loads(data)    # str -> json으로 변환
-                json.dump(json_data, f, ensure_ascii=False) # json을 원형 그대로 파일에 저장(인코딩 깨짐을 방지)
-                print(json_data)
-                return True
-        except BaseException as e:
-            print("Error on_data: %s" % str(e))
+        with open('sample.json', 'a', encoding='utf-8') as f:
+            json_data = json.loads(data)    # str -> json으로 변환
+            json.dump(json_data, f, ensure_ascii=False) # json을 원형 그대로 파일에 저장(인코딩 깨짐을 방지)
+            print(json_data)
         return True
 
     def on_error(self, status):