autoCommit 20240229.163512

Author: atj61275

data/youtube_comments.db

@@ -0,0 +1,46 @@
+from googleapiclient.discovery import build
+import sqlite3
+
+# YouTube API setup
+API_KEY = 'AIzaSyAZJRxunHxliV4-xAfvxi6LKEIDjb5ItiM';
+youtube = build('youtube', 'v3', developerKey=API_KEY)
+
+path = '../data/youtube_comments.db'
+
+# Database setup
+conn = sqlite3.connect(path)
+cursor = conn.cursor()
+
+def fetch_comments(video_id, search_string):
+    comments = []
+    response = youtube.commentThreads().list(
+        part='snippet',
+        videoId=video_id,
+        maxResults=100,  # Adjust based on your needs
+        textFormat='plainText'
+    ).execute()
+
+    for item in response['items']:
+        comment = item['snippet']['topLevelComment']['snippet']['textDisplay']
+        if search_string.lower() in comment.lower():
+            comments.append(comment)
+            if len(comments) == 3:
+                break
+
+    return comments
+
+def insert_comments_into_db(video_id, comments):
+    for comment in comments:
+            sql = "INSERT INTO `youtube_comments` (`video_id`, `comment`) VALUES (?, ?)"
+            cursor.execute(sql, (video_id, comment))
+    conn.commit()
+
+video_ids = ['HQKwgk6XkIA', 'qGyp0Y5ewBI']  # Your video IDs
+search_string = '2'  # String to search in comments
+
+for video_id in video_ids:
+    comments = fetch_comments(video_id, search_string)
+    if comments:
+        insert_comments_into_db(video_id, comments)
+
+conn.close()

fetch_comments_to_db.py

@@ -0,0 +1,25 @@
+import sqlite3
+import os
+
+path = '../data/youtube_comments.db'
+import os
+if os.path.exists(path):
+  os.remove(path)
+else:
+  print("The file does not exist")
+
+# Connect to SQLite database (this will create the database file if it doesn't exist)
+conn = sqlite3.connect(path)
+cursor = conn.cursor()
+sql = '''CREATE TABLE youtube_comments (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            video_id TEXT NOT NULL,
+            comment TEXT NOT NULL
+        )'''
+cursor.execute(sql)
+
+# Commit your changes in the database
+conn.commit()
+conn.close()
+
+print("Table created successfully")

src/o1_create_empty_db.py

@@ -0,0 +1,50 @@
+from googleapiclient.discovery import build
+import sqlite3
+
+# YouTube API setup
+API_KEY = 'AIzaSyAZJRxunHxliV4-xAfvxi6LKEIDjb5ItiM';
+youtube = build('youtube', 'v3', developerKey=API_KEY)
+
+path = '../data/youtube_comments.db'
+
+# Database setup
+conn = sqlite3.connect(path)
+cursor = conn.cursor()
+
+def fetch_comments(video_id, search_string):
+    comments = []
+    response = youtube.commentThreads().list(
+        part='snippet',
+        videoId=video_id,
+        order='relevance',
+        maxResults=1000,
+        textFormat='plainText'
+    ).execute()
+
+    for item in response['items']:
+        comment = item['snippet']['topLevelComment']['snippet']
+        if search_string.lower() in comment['textDisplay'].lower():
+            comments.append({
+                'author': comment['authorDisplayName'],
+                'text': comment['textDisplay'],
+                'likes': comment['likeCount'],
+                'publishedAt': comment['publishedAt']
+            })
+    sorted_comments = sorted(comments, key=lambda x: x['likes'], reverse=True)
+    return sorted_comments[0:3]
+
+def insert_comments_into_db(video_id, comments):
+    for comment in comments:
+            sql = "INSERT INTO `youtube_comments` (`video_id`, `comment`) VALUES (?, ?)"
+            cursor.execute(sql, (comment['author'], comment['text']))
+    conn.commit()
+
+video_ids = ['qGyp0Y5ewBI', 'BSXoI9MDvU0']  # Your video IDs
+search_string = ''  # String to search in comments
+
+for video_id in video_ids:
+    comments = fetch_comments(video_id, search_string)
+    if comments:
+        insert_comments_into_db(video_id, comments)
+
+conn.close()

src/o2_fetch_comments_to_db.py

@@ -0,0 +1,22 @@
+from flask import Flask, render_template
+import sqlite3
+
+app = Flask(__name__)
+
+path = '../data/youtube_comments.db'
+
+def get_comments():
+    conn = sqlite3.connect(path)
+    cursor = conn.cursor()
+    cursor.execute("SELECT video_id, comment FROM youtube_comments")
+    comments = cursor.fetchall()
+    conn.close()
+    return comments
+
+@app.route('/')
+def show_comments():
+    comments = get_comments()
+    return render_template('comments.html', comments=comments)
+
+if __name__ == '__main__':
+    app.run(debug=True)

src/o3_flask_load_db.py

@@ -0,0 +1,15 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <title>YouTube Comments</title>
+</head>
+<body>
+    <h1>YouTube Comments</h1>
+    <ul>
+        {% for video_id, comment in comments %}
+            <li><strong>NAME:</strong> {{ video_id }}  <strong>Comment:</strong> {{ comment }}</li>
+        {% endfor %}
+    </ul>
+</body>
+</html>