SlackのメッセージをX（旧Twitter）に自動投稿する方法（Lambda × API Gateway × SSM）

Last updated at 2025-06-01Posted at 2025-05-31

📝 本記事の前提と目的

本記事は筆者自身が学んだ知識をもとにテーマを設定し、構築・検証した結果をアウトプットとしてまとめた記録です。
テーマ選定の背景として、現在所属しているスクールにおいてSlackを使用して進捗報告を行っており、その内容を自身のX（旧Twitter）においても活動報告として投稿できればと考えたことがきっかけです。
構成はすべて無料プランの範囲内で完結します。
- Slack：無料アカウントで利用可能
- X（旧Twitter）：無料開発者アカウントを利用
- AWS：無料利用枠（Free Tier）を前提
有料プランや追加課金が必要な構成要素は一切使用していません。
本記事の内容は2025年5月31日時点の構成・画面・仕様に基づいて動作確認されています。

🔷 全体の流れ（手順一覧）

この自動投稿システムは、Slackの特定チャンネルに投稿されたメッセージをトリガーに、AWS Lambdaを経由してX（旧Twitter）へ自動で投稿する構成です。

以下の6ステップで構成されます：

Slackの環境構築：アカウント、ワークスペース、チャンネルの作成
X API設定：認証情報の取得と設定
Lambda構築：モジュールのZIP化と関数作成
API Gateway連携：SlackとLambdaの接続設定
Slackアプリ作成とBot設定：イベントと権限付与
動作確認：Slackからの投稿がXに反映されることを確認

それでは各手順を順に詳しく解説していきます。

🧩 事前準備：Slackのワークスペースとチャンネル作成

0-1. Slackアカウントの作成

Slack公式サイトにアクセスし、「Slackを始める」からアカウントを作成します。
メールアドレスを登録し、認証コードを入力して進みます。

0-2. ワークスペースの作成

アカウント作成後、「新しいワークスペースを作成」画面が表示されるので、以下の項目を入力：

プロジェクトやチームの名前（例：MyDevWorkspace）

名前（例：テスト）

※スキップしてください
※スキップしてください

0-3. チャンネルの作成

Slackワークスペースにログイン後、左側の「チャンネル」セクションで「＋チャネルを追加する」をクリック
「次へ」ボタンをクリック
任意のチャンネル名を設定（例：#auto-post）
可視性の設定はデフォルトのまま
「作成」ボタンをクリック
「後でする」ボタンをクリック

※ 後ほどこのチャンネルにBotを招待し、投稿をトリガーに使用します。

🧩 手順①：X（旧Twitter）APIの設定

💡 注意ポイント

本構成では、認証設定画面で「OAuth 2.0（User Context）」の前提でトークンを取得し、Lambda からの投稿処理に使用します。

App Context や OAuth 1.0 を利用した場合、tweet.write 権限があっても投稿処理が失敗することがあります。

認証用のトークンは複数ありますが、今回の構成ではBearer Tokenを使用します。Lambda関数からの認証で必要です。

無料プランでもAPIキーは取得可能ですが、設定を誤ると認証エラーや投稿失敗の原因となるため、画面通りに設定を行ってください。

1-1. X Developer Portal にアクセス

https://developer.x.com/ にログイン
右上の「Developer Portal」をクリック
中央に表示されている「+ Create Project」クリック

1-2. プロジェクトとアプリの設定

Project名（例：SlackXPoster）を入力
Use case（例：Exploring the API）を設定
Projekuct description：「Web App, Automated App or Bot」を入力
App名（例：SlackXPoster）を入力
画面で表示される以下の内容をメモし、「App setting」をクリック
- API KEY
- API Key Secret
- Bearer Token

1-3. User authentication settings の設定

App permissions：「Read and write」を選択
※ 投稿操作に「Write」権限が必要です
Type of App：「Web App, Automated App or Bot」を選択
※Botとして扱うためこの設定にします
Callback URL：https://example.com/callback（ダミーでOK）を入力
※空欄では保存できないため適当なURLを設定（実際には使用しません）
Website URL：任意のURLを入力（例：[https://localhost.com])
※空欄でなければOK
「Save」ボタンをクリックして設定を保存

⚠ 保存時にエラーが出た場合は、URL項目が空欄でないかを確認してください

※以下は使用しません

※以下は使用しません

1-4. 公開鍵/秘密鍵の取得の設定

ポータルの左メニューより「Projects ＆ Apps」を選択し、対象のアプリを選択
中央のアプリ名の下にある「Keys and tokens」を選択
Access Token and Secretより「Regenerate」をクリック
画面で表示される以下の内容をメモ
- Access Token
- Access Token Secret

🧩 手順②：Lambdaとモジュールの準備（ローカル環境）

💡 注意ポイント

lambda_function.py はZIPのルートディレクトリに配置する必要があります。
モジュールのZIPを作る際、必ず依存ライブラリ（tweepyなど）を同じディレクトリに展開してください。
pip install -t . によってできるサブディレクトリをZIPに含め忘れると、Lambda実行時に ModuleNotFoundError になります。

2-1. tweepyを含むLambdaパッケージ（ZIP）の作成

※ Pythonの仮想環境は使用せず、カレントディレクトリに直接モジュールをインストールする方法で進めます。

# tweepy用の作業ディレクトリを作成します
mkdir tweepy_layer

# 作成したディレクトリに移動します
cd tweepy_layer

# tweepyライブラリを現在のディレクトリ（=ZIP化対象）にインストールします
# Lambdaで直接使用できるように仮想環境は使わずにローカルに展開します
pip install tweepy -t .

以下は実行例です

2-2. lambda_function.py を同フォルダに保存

※意図的にコメントを多く入れています

# -------------------------------
# 必要なライブラリを読み込みます
# -------------------------------
import json        # 文字列をPythonの辞書に変換するために使用
import boto3       # AWSのサービス（SSM）を操作するために使用
import tweepy      # X（旧Twitter）に投稿するためのライブラリ

# -------------------------------
# SSM（パラメータストア）から各種キーを安全に取得します
# -------------------------------
def get_param(name):
    ssm = boto3.client('ssm')
    return ssm.get_parameter(Name=name, WithDecryption=True)['Parameter']['Value']

# -------------------------------
# 認証情報をSSMから取得します（事前にAWS Systems Manager Parameter Storeに登録しておく必要があります）
# 各キーの役割は以下のとおりです：
# 
#   /slack-to-x/BEARER_TOKEN     → X APIのベアラートークン（読み取りなどに使用、投稿には不要な場合あり）
#   /slack-to-x/ACCESS_TOKEN     → 投稿するユーザーのアクセストークン（OAuth 1.0aで使用）
#   /slack-to-x/ACCESS_SECRET    → 上記トークンに対応する秘密鍵（署名に必要）
#   /slack-to-x/CONSUMER_KEY     → アプリの識別用ID（API Keyとも呼ばれる）
#   /slack-to-x/CONSUMER_SECRET  → アプリの秘密鍵（Consumer Keyとセットで使う）
#
# 投稿機能を使うには CONSUMER_KEY/SECRET + ACCESS_TOKEN/SECRET の4つが必要です。
# BEARER_TOKEN はOAuth 2.0の認証用トークンで、読み取りAPIなどで使われます。
# -------------------------------
BEARER_TOKEN    = get_param('/slack-to-x/BEARER_TOKEN')
ACCESS_TOKEN    = get_param('/slack-to-x/ACCESS_TOKEN')
ACCESS_SECRET   = get_param('/slack-to-x/ACCESS_SECRET')
CONSUMER_KEY    = get_param('/slack-to-x/CONSUMER_KEY')
CONSUMER_SECRET = get_param('/slack-to-x/CONSUMER_SECRET')

# -------------------------------
# tweepy（X APIクライアント）を初期化します
# -------------------------------
client = tweepy.Client(
    bearer_token=BEARER_TOKEN,
    consumer_key=CONSUMER_KEY,
    consumer_secret=CONSUMER_SECRET,
    access_token=ACCESS_TOKEN,
    access_token_secret=ACCESS_SECRET
)

# -------------------------------
# Lambdaのメイン処理です
# -------------------------------
def lambda_handler(event, context):
    print("📩 Slackイベントを受信しました:", json.dumps(event))

    # -------------------------------
    # Slackの再送処理（retry）に対応します
    # -------------------------------
    if "headers" in event:
        headers = event["headers"]
        retry_num = headers.get("X-Slack-Retry-Num")

        # 再送回数が3回以上なら処理をスキップ
        if retry_num is not None:
            try:
                if int(retry_num) >= 3:
                    print(f"🚫 リトライ上限（{retry_num}回）を超えたため処理しません")
                    return {
                        "statusCode": 200,
                        "body": json.dumps("Retry limit exceeded, skipping")
                    }
            except ValueError:
                print("⚠️ リトライ回数の形式が不正です")

        # 通常の再送検知ログ（1回目〜2回目）
        if "X-Slack-Retry-Num" in headers:
            print(f"🔁 Slackリトライ検知: retry_num = {retry_num}")

    try:
        # -------------------------------
        # JSON形式のリクエストボディを辞書に変換します
        # -------------------------------
        body = json.loads(event.get("body", "{}"))

        # -------------------------------
        # SlackからのURL検証リクエストに応答します
        # -------------------------------
        if body.get("type") == "url_verification":
            print("🔐 URL検証リクエストを受信しました")
            return {
                "statusCode": 200,
                "headers": {"Content-Type": "application/json"},
                "body": json.dumps({"challenge": body.get("challenge")})
            }

        # -------------------------------
        # Slackイベント本体（メッセージ内容など）を取り出します
        # -------------------------------
        event_data = body.get("event", {})

        # Bot（自分自身など）が投稿したメッセージは無視します（ループ防止）
        if event_data.get("bot_id"):
            print("🤖 Botによる投稿のため処理をスキップします")
            return {
                "statusCode": 200,
                "body": json.dumps("Bot message ignored")
            }

        # -------------------------------
        # 投稿内容（text）を取得し、空白を除去します
        # -------------------------------
        text = event_data.get("text", "").strip()

        # -------------------------------
        # textが空の場合、blocksの中からテキストを補完取得します
        # -------------------------------
        if not text:
            blocks = event_data.get("blocks", [])
            for block in blocks:
                if block.get("type") == "section":
                    text_candidate = block.get("text", {}).get("text", "").strip()
                    if text_candidate:
                        text = text_candidate
                        print(f"🧩 blocksからテキストを取得: {text}")
                        break

        # 内容が空の場合は投稿しません
        if not text:
            print("⚠️ メッセージが空のため処理をスキップします")
            return {
                "statusCode": 200,
                "body": json.dumps("No text to tweet")
            }

        # -------------------------------
        # Xに投稿するメッセージを作成し投稿します
        # -------------------------------
        tweet_text = f"{text}（自動投稿）"
        print(f"✍️ 投稿内容: {tweet_text}")
        client.create_tweet(text=tweet_text)
        print("✅ Xへの投稿が完了しました")

        return {
            "statusCode": 200,
            "body": json.dumps("Tweeted successfully")
        }

    # -------------------------------
    # 投稿制限（429エラー）の場合はSlackに成功応答を返し、再送を防ぎます
    # -------------------------------
    except tweepy.errors.TooManyRequests as e:
        print(f"❌ 投稿制限（429）に達しました: {str(e)}")
        return {
            "statusCode": 200,
            "body": json.dumps("Rate limit exceeded, skipping retry")
        }

    # -------------------------------
    # 他の予期しないエラーもSlackに成功と返し、再送されないようにします
    # -------------------------------
    except Exception as e:
        print(f"❌ 予期せぬエラーが発生しました: {str(e)}")
        return {
            "statusCode": 200,
            "body": json.dumps("Unexpected error occurred, retry skipped")
        }

2-3. ファイル構成の確認

以下のようなディレクトリ構成に最終的になっていれば準備完了です：

tweepy_layer/
├── lambda_function.py
├── tweepy/（インストールされたライブラリ）
├── requests/（依存ライブラリ）
└── その他の必要なライブラリ/

3-4. モジュールをZip形式でパッケージ化する

# Windows環境でのZIPファイル作成コマンドです
# このコマンドはカレントディレクトリ配下のすべてのファイルとフォルダをZIPに圧縮します
# 作成されたZIPファイル（tweepy_lambda.zip）はLambdaへアップロードします
Compress-Archive -Path * -DestinationPath tweepy_lambda.zip

以下は実行例です

🧩 手順③：AWS Lambda関数の作成と環境変数の設定

💡 注意ポイント

Lambda作成時に指定するロールには「SSM読み取り権限」が含まれている必要があります。
コードアップロード後は「保存」を忘れずに。
SSMのパラメータ名とコード内のキー名（パス）は完全一致していないと読み取りに失敗します。
Lambda関数の**タイムアウト（実行時間制限）**はデフォルトでは3秒と短いため、10〜15秒に延長しておくのが安全です。

3-1. Lambda関数の作成

AWSマネジメントコンソールにログインし、サービスから「Lambda」を選択
「関数の作成」をクリック
以下の内容で入力：
- 関数名：SlackToXPoster
- ランタイム：Python 3.11
- 実行ロール：基本的なLambda権限付きの新規ロールを作成
[関数の作成] をクリックして完了

3-2. ZIPファイルのアップロード

「コード」タブを開き、「.zipファイルをアップロード」を選択
作成済みの tweepy_lambda.zip をアップロード
「保存」をクリック

✅ LambdaにSSM読み取り権限を付与

Lambda関数 → [設定] → [編集] を開く
既存のロールにて「ロールの表示」を開く
IAMロールを開き、以下の通り許可の追加
「ポリシーのアタッチ」 → [AmazonSSMReadOnlyAccess] の許可を追加

このようにすれば、Lambda環境変数に直接キーを保存する必要がなくなり、安全性が大幅に向上します。

3-3. Lambdaのタイムアウト設定変更

Lambda関数詳細ページで「設定」タブをクリック
一般設定セクションにある「タイムアウト」の右側の編集ボタンをクリック
「15秒」に変更して「保存」ボタンをクリック

3-4. パラメータストアによる秘匿情報の安全な管理（必須）

環境変数ではなく、AWS Systems Manager Parameter Store に各種APIキーを安全に保存し、Lambda関数内で取得する方法を推奨します。

✅ SSMパラメータの登録手順

AWSマネジメントコンソール → Systems Manager → 「パラメータストア」→「パラメータの作成」
以下の項目を入力（1つずつ作成）：
- 名前: /slack-to-x/BEARER_TOKEN（任意のパス構成でOK）
- タイプ: 「SecureString」※安全な文字列
- 値: 実際のトークンやキーを入力　※事前にxにて取得した値を設定
- KMSキーはデフォルトのままでOK
同様に以下の5つを作成：
- /slack-to-x/BEARER_TOKEN　※Bearer Token
- /slack-to-x/ACCESS_TOKEN　※Access Token
- /slack-to-x/ACCESS_SECRET　※Access Token Secret
- /slack-to-x/CONSUMER_KEY　　※API Key
- /slack-to-x/CONSUMER_SECRET　※API Key Secret

※他同様

🧩 手順④：API Gatewayの作成とSlackとの接続

💡 注意ポイント

API Gatewayの通信方式は「HTTP API」を選択してください。REST APIではSlackとの統合が正常に動作しない可能性があります。
SlackからのリクエストはHTTPSである必要があるため、API GatewayエンドポイントのURLスキーム（https://）を必ず確認してください。
API Gatewayで統合対象のLambda関数を誤るとSlackからリクエストが届かなくなります。
SlackのEvent Subscriptionsで「Verified」と表示されない場合、Lambdaの実行権限や戻り値の形式（JSON）を見直してください。

4-1. HTTP APIの作成

AWSマネジメントコンソールで「API Gateway」を開く
「APIを作成」→「HTTP API」を選択
　API名「SlackToXPoster」
「統合」→「Lambda関数」を選択
　Lambda関数にて「SlackToXPoster」関数を指定
[デプロイステージ] は default でOK → 作成完了
発行された「エンドポイントURL」を控える

Lambdaの「+トリガーを追加」からでも作成できます

🧩 手順⑤：Slack Appの作成と設定

💡 注意ポイント

Event Subscriptionsの「Request URL」には、必ず後で発行される「API GatewayのエンドポイントURL」を正確に入力してください。未設定または誤りがあるとSlackの検証が通らず「Verified」になりません。
chat:write スコープがないとBotが投稿できません。
Botをチャンネルに招待しないとイベントが受け取れません。必ず /invite @Bot名 を実行してください。

5-1. Slack Appを作成

Slack API にアクセス
[Create New App] → [From scratch] をクリック
App Nameに「SlackToXBot」と入力
作成したワークスペースを選択 → [Create App]

5-2. Bot権限の設定（OAuth & Permissions）

左メニューから [OAuth & Permissions] を選択
下へスクロールし「Scopes」の「Bot Token Scopes」を追加：
- chat:write：投稿権限
- channels:read：チャンネル一覧取得
- channels:history：チャンネルメッセージ取得
- im:history：DMメッセージ取得

設定前

設定後

Request URLがないと設定できないので一旦スキップ

5-3. イベントサブスクリプション設定

左メニュー「Event Subscriptions」
[Enable Events] を ON
「Request URL」欄は後でAPI GatewayのURLを設定（仮で空欄OK）
下の [Subscribe to bot events] → 「Add Bot User Event」ボタン
- message.channels
- message.im