File size: 2,183 Bytes
677c9b1
 
a40dd85
677c9b1
a40dd85
 
677c9b1
 
 
 
 
 
 
 
 
 
 
a40dd85
 
 
 
677c9b1
a40dd85
677c9b1
 
a40dd85
 
 
 
 
 
677c9b1
 
a40dd85
677c9b1
a40dd85
677c9b1
 
a40dd85
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
import os
import json
import requests
from google.oauth2 import service_account
from google.auth.transport.requests import Request
from googleapiclient.discovery import build

# 環境変数からサービスアカウントのJSON内容を取得
service_account_info = os.getenv('GOOGLE_APPLICATION_CREDENTIALS_CONTENT')

if service_account_info is None:
    raise ValueError("サービスアカウントのJSON内容が設定されていません。")

# JSON文字列を辞書に変換
service_account_info_dict = json.loads(service_account_info)

# サービスアカウント情報を使用して認証情報を作成
credentials = service_account.Credentials.from_service_account_info(
    service_account_info_dict,
    scopes=['https://www.googleapis.com/auth/chat.bot']  # 必要なスコープを指定
)

# Google Chat APIクライアントを作成
chat_service = build('chat', 'v1', credentials=credentials)

# メッセージを送信するスペースの名前(適切な形式に修正)
space_name = 'spaces/AAAAv_S3Bco'  # ここを実際のスペースIDに置き換えてください

# 初回メッセージを送信
initial_message = {
    'text': 'スレッドへ返信に変更テスト'
}

initial_response = chat_service.spaces().messages().create(
    parent=space_name,
    body=initial_message
).execute()

# スレッドキーを取得
thread_name = initial_response['thread']['name']
print('Initial message sent. Thread name:', thread_name)

return thread_name


# 後続のメッセージをスレッド内に送信するためのURLを構築
url = f'https://chat.googleapis.com/v1/{space_name}/messages?messageReplyOption=REPLY_MESSAGE_OR_FAIL'

# 後続のメッセージをスレッド内に送信
follow_up_message = {
    'text': 'スレッドへ返信.',
    'thread': {
        'name': thread_name
    }
}

# アクセストークンを取得
credentials.refresh(Request())
access_token = credentials.token

headers = {
    'Authorization': f'Bearer {access_token}',
    'Content-Type': 'application/json'
}

response = requests.post(url, headers=headers, data=json.dumps(follow_up_message))

print('Follow-up message sent:', response.json())