public void pullLogs()

in src/main/java/com/aliyun/openservices/log/sample/PullLogsSample.java [55:92]

33 lines of code
7 McCabe index (conditional complexity)


	public void pullLogs(int shardId) {
		try {
			GetCursorResponse cursorRes = client.GetCursor(project,
					logStore, shardId, CursorMode.BEGIN);
			String cursor = cursorRes.GetCursor();
			int iteration = 100;

			for (int i = 0; i < iteration; i++) {
				PullLogsRequest request = new PullLogsRequest(project, logStore, shardId, 1000, cursor);
				PullLogsResponse response = client.pullLogs(request);

				String next_cursor = response.getNextCursor();
				System.out.print("The Next cursor:" + next_cursor);

				List<LogGroupData> logGroups = response.getLogGroups();
				for (LogGroupData logGroup : logGroups) {
					FastLogGroup fastLogGroup = logGroup.GetFastLogGroup();
					System.out.println("Source:" + fastLogGroup.getSource());
					System.out.println("Topic:" + fastLogGroup.getTopic());
					for (FastLog log : fastLogGroup.getLogs()) {
						System.out.println("LogTime:" + log.getTime());
						List<FastLogContent> contents = log.getContents();
						for (FastLogContent content : contents) {
							System.out.println(content.getKey() + ":" + content.getValue());
						}
					}
				}

				if (cursor.equals(next_cursor)) {
					break;
				}
				cursor = next_cursor;
			}

		} catch (LogException e) {
			e.printStackTrace();
		}
	}