Amazon Bedrock を使って毎朝 IT ニュースを Slack に通知するシステムを作ってみた

# AWS CLIの認証情報を設定する
aws configure

AWS Access Key ID:     → 先ほどコピーしたアクセスキー IDを貼り付け
AWS Secret Access Key: → 先ほどコピーしたシークレットアクセスキーを貼り付け
Default region name:   → ap-northeast-1 であればそのまま Enter
Default output format: → json でよければそのまま Enter

# SAM CLI のインストール ( Homebrew 経由)
brew install aws-sam-cli

aws sts get-caller-identity

{
    "UserId": "AIDAXXXXXXXXXXXXXXXXX",
    "Account": "123456789012",   ← 想定されたアカウント ID か確認   
 "Arn": "arn:aws:iam::123456789012:user/news-bot-user"
}

it-news-system/             
├── template.yaml 
├── samconfig.toml 
├── Makefile 
└── functions/ 
　　└── news_collector/ 
　　　　　　　├── handler.py 
　　　　　　　└── requirements.txt

AWSTemplateFormatVersion: '2010-09-09'
Transform: AWS::Serverless-2016-10-31
Description: "ITニュース自動収集＆Slack通知システム - SAM版"

Parameters:
  BedrockRegion:
    Type: String
    Default: "us-east-1"
    Description: "Amazon Nova Liteを使用するリージョン"
  SlackWebhookUrl:
    Type: String
    NoEcho: true
    Description: "SlackのIncoming Webhook URLを入力してください"
  ScheduleExpression:
    Type: String
    Default: "cron(0 23 * * ? *)"
    Description: "収集スケジュール（UTC指定。デフォルトはJST朝8時）"

Globals:
  Function:
    Runtime: python3.13
    Timeout: 300
    MemorySize: 256
    Environment:
      Variables:
        BEDROCK_REGION: !Ref BedrockRegion
        SLACK_WEBHOOK_URL: !Ref SlackWebhookUrl

Resources:
  NewsCollectorFunction:
    Type: AWS::Serverless::Function
    Properties:
      FunctionName: "it-news-slack-bot"
      CodeUri: functions/news_collector/
      Handler: handler.lambda_handler
      Policies:
        - Statement:
            - Effect: Allow
              Action:
                - bedrock:InvokeModel
              Resource: !Sub "arn:aws:bedrock:${BedrockRegion}::foundation-model/amazon.nova-lite-v1:0"
      Events:
        DailySchedule:
          Type: Schedule
          Properties:
            Schedule: !Ref ScheduleExpression

Outputs:
  LambdaFunctionName:
    Description: "作成されたLambda関数名"
    Value: !Ref NewsCollectorFunction

version = 0.1
[default.deploy.parameters]
stack_name = "it-news-slack-bot"
resolve_s3 = true
s3_prefix = "it-news-slack-bot"
region = "ap-northeast-1"
confirm_changeset = true
capabilities = "CAPABILITY_IAM"

.PHONY: build deploy delete

build:
	sam build

deploy: build
	sam deploy --guided

delete:
	sam delete --stack-name it-news-slack-bot --region ap-northeast-1 
--no-prompts

boto3>=1.35.79

import os
import json
import logging
import urllib.request
import xml.etree.ElementTree as ET
import re

import boto3
from botocore.exceptions import ClientError

logger = logging.getLogger()
logger.setLevel(logging.INFO)

# 環境変数からSlack/Bedrockの設定を読み込みます
BEDROCK_REGION = os.environ.get("BEDROCK_REGION", "us-east-1")
SLACK_WEBHOOK_URL = os.environ.get("SLACK_WEBHOOK_URL")

bedrock = boto3.client("bedrock-runtime", region_name=BEDROCK_REGION)
MODEL_ID = "amazon.nova-lite-v1:0"  # Amazon Bedrockで使うAIモデル

# ここにお好みのRSSフィードを追加できます
RSS_FEEDS = [
    {"name": "Hacker News", "url": "https://news.ycombinator.com/rss"},
    {"name": "TechCrunch",  "url": "https://techcrunch.com/feed/"},
    {"name": "ITmedia",     "url": "https://rss.itmedia.co.jp/rss/2.0/itmedia_all.xml"},
]

def fetch_rss(url, max_items=2):
    """指定したRSSフィードから記事を最大max_items件取得する"""
    items = []
    try:
        req = urllib.request.Request(url, headers={"User-Agent": "Mozilla/5.0"})
        with urllib.request.urlopen(req, timeout=10) as response:
            root = ET.fromstring(response.read())
        for item in root.findall(".//item")[:max_items]:
            title = item.findtext("title", default="無題")
            link  = item.findtext("link",  default="")
            desc  = re.sub(r"<.*?>", "", item.findtext("description", default=""))[:300]
            items.append({"title": title, "link": link, "desc": desc})
    except Exception as e:
        logger.error(f"RSS取得エラー ({url}): {e}")
    return items

def summarize_with_nova(title, desc):
    """Amazon Bedrockのプロンプトを組み立て、Nova Liteで記事を日本語3行要約する"""
    prompt = (
        f"以下のITニュースをエンジニア向けに日本語で3行以内で要約してください。\n\n"
        f"タイトル: {title}\n内容: {desc}\n\n要約:"
    )
    try:
        response = bedrock.converse(
            modelId=MODEL_ID,
            messages=[{"role": "user", "content": [{"text": prompt}]}],
            inferenceConfig={"maxTokens": 200, "temperature": 0.3},
        )
        return response["output"]["message"]["content"][0]["text"].strip()
    except ClientError as e:
        logger.error(f"Amazon Bedrockエラー: {e}")
        return "要約の生成に失敗しました。"

def post_to_slack(text):
    """Slackのウェブフック宛てにメッセージをPOSTする"""
    if not SLACK_WEBHOOK_URL:
        logger.warning("SLACK_WEBHOOK_URLが未設定です。環境変数を確認してください。")
        return
    payload = {"text": text}
    req = urllib.request.Request(
        SLACK_WEBHOOK_URL,
        data=json.dumps(payload).encode("utf-8"),
        headers={"Content-Type": "application/json"},
    )
    with urllib.request.urlopen(req, timeout=10):
        logger.info("Slackへの投稿に成功しました！")

def lambda_handler(event, context):
    """Lambdaのエントリーポイント。EventBridgeから毎朝ここが呼ばれます。"""
    logger.info("ニュース収集を開始します")
    lines = ["*📰 今朝のITニュースまとめ（Amazon Bedrock によるAI要約）*"]
    for feed in RSS_FEEDS:
        articles = fetch_rss(feed["url"])
        if articles:
            lines.append(f"\n*{feed['name']}*")
            for a in articles:
                summary = summarize_with_nova(a["title"], a["desc"])
                lines.append(f"• <{a['link']}|{a['title']}>\n  _{summary}_")
    post_to_slack("\n".join(lines))
    return {"statusCode": 200, "body": "OK"}

make deploy

Stack Name [it-news-slack-bot]: → そのままEnter
AWS Region [ap-northeast-1]: → ap-northeast-1 であればそのまま Enter
Parameter BedrockRegion [us-east-1]: → そのままEnter
Parameter SlackWebhookUrl:　→ 取得したWebhook URLを貼り付けてEnter
Parameter ScheduleExpression [cron(0 23 * * ? *)]: → そのまま Enter
Confirm changes before deploy [Y/n]: → そのまま Enter
Allow SAM CLI IAM role creation [Y/n]: → そのまま Enter
Disable rollback [y/N]: → そのまま Enter
Save arguments to configuration file [Y/n]: → そのまま Enter
SAM configuration file [samconfig.toml]: → そのまま Enter
SAM configuration environment [default]: → そのまま Enter
Deploy this changeset? [y/N]: → y を入力してEnter

make delete