&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<h2 data-pm-slice="1 1 []">1. 슬랙 채널의 데이터</h2>각자 준비&nbsp;<h2>2. Docker-compose를 사용한 mongodb 설치</h2><div style="background-color:#1e1f22;color:#bcbec4;"><pre style="font-family:'JetBrains Mono',monospace;font-size:9.8pt;">version: "3" services: mongodb: image: mongo:7.0.2 container_name: mongodb restart: always environment: - MONGO_INITDB_ROOT_USERNAME=rootuser - MONGO_INITDB_ROOT_PASSWORD=rootpass volumes: - mongo-data:/data ports: - "27017:27017" volumes: mongo-data: driver: local &nbsp;</pre></div>&nbsp;<h2>3. 최대한 공수를 줄이기 위한 파이썬으로 mongodb에 데이터 넣기</h2>requirements.txt<div style="background-color:#1e1f22;color:#bcbec4;"><pre style="font-family:'JetBrains Mono',monospace;font-size:9.8pt;">dnspython==2.4.2 pymongo==4.5.0 pytz==2023.3.post1 &nbsp;</pre></div>&nbsp;main.py<div style="background-color:#1e1f22;color:#bcbec4;"><pre style="font-family:'JetBrains Mono',monospace;font-size:9.8pt;">import glob import json import os from datetime import datetime from urllib.parse import quote_plus import pymongo import pytz # 사용자 이름과 비밀번호 username = "rootuser" password = "rootpass" # 연결 문자열 생성 connection_string = f"mongodb://{quote_plus(username)}:{quote_plus(password)}@localhost:27017/" client = pymongo.MongoClient(connection_string) # 데이터베이스 선택 (없으면 자동으로 생성됨) db = client["slack"] # 컬렉션(테이블과 유사한 개념) 선택 (없으면 자동으로 생성됨) collection = db["c2c"] # JSON 파일이 있는 폴더의 경로 folder_path = "/Users/nwkim/Downloads/alert-c2c-ndp" # 폴더 내의 JSON 파일 목록 가져오기 json_files = glob.glob(os.path.join(folder_path, "*.json")) def addTimestamp(data): if "ts" in data: ts_value = float(data["ts"]) timestamp = datetime.fromtimestamp(ts_value).astimezone(pytz.timezone('Asia/Seoul')).strftime("%Y-%m-%d %H:%M:%S%z") data["timestamp"] = timestamp # JSON 파일을 몽고DB에 넣기 for json_file in json_files: with open(json_file, "r") as file: json_data = json.load(file) if isinstance(json_data, list): # JSON 데이터가 리스트 형식인 경우 for item in json_data: addTimestamp(item) collection.insert_one(item) else: addTimestamp(json_data) collection.insert_one(json_data) print(f"JSON 데이터 {json_file}이 몽고DB에 성공적으로 삽입되었습니다.") # 연결 닫기 client.close() &nbsp;</pre></div>&nbsp;<h2>4. 쿼리</h2>ref. <a href="https://cocoder16.tistory.com/72" data-inline-card="" data-card-data="">https://cocoder16.tistory.com/72</a>&nbsp;<div style="background-color:#1e1f22;color:#bcbec4;"><pre style="font-family:'JetBrains Mono',monospace;font-size:9.8pt;">//예시 db.c2c.find({ "attachments": { $elemMatch: { "fields": { $elemMatch: { "title": { $regex: /Connection is closed/i } } } } } }) .sort({ts: -1}); ; // 자바스크립트 구문으로도 사용 가능 var filter = { "attachments": { $elemMatch: { "fields": { $elemMatch: { "title": { $regex: /Connection is closed/i } } } } } }; // 카운트 쿼리를 실행합니다. db.c2c.find(filter).count(function(err, count) { if (err) { console.error("카운트 작업 중 오류가 발생했습니다."); } else { console.log("검색된 문서 수: " + count); } }); &nbsp;</pre></div>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;

슬랙 채널의 데이터를 mongodb에 적재 후 필터링 하기