自分はどちらかと言うとインフラ寄りの CI/CD エンジニアなのですが、専門外の私にも ChatGPT との連携を検証する日がやって来ました。いちユーザーとして ChatGPT を使うだけの幸せな日常から、仕事として携わる日も近いかもしれません。という事で趣味がてら EchoBot.cs をいじって OpenAI の REST API に会話を送ったり、CosmosDB にチャット履歴を保存したりを試してみました。
C# VSCode CLI でボットアプリを作成
こちらのドキュメントを参考にボットアプリを作成します。
bash
$ dotnet --version
6.0.300
$ dotnet new -i Microsoft.Bot.Framework.CSharp.EchoBot
次のパッケージがインストールされます:
Microsoft.Bot.Framework.CSharp.EchoBot
Microsoft.Bot.Framework.CSharp.EchoBot は既にインストールされています。バージョン: 4.17.1、バージョン に置き換えられます。
Microsoft.Bot.Framework.CSharp.EchoBot::4.17.1 が正常にアンインストールされました。
成功: Microsoft.Bot.Framework.CSharp.EchoBot::4.17.1により次のテンプレートがインストールされました。
テンプレート名 短い名前 言語 タグ
-------------------------------- -------- ---- -----------------------------------------------
Bot Framework Echo Bot (v4.17.1) echobot [C#] Bot/Bot Framework/Echo Bot/Conversational AI/AI
$ dotnet new echobot -n mnrechobot
テンプレート "Bot Framework Echo Bot (v4.17.1)" が正常に作成されました。
作成後の操作を処理しています...
復元するプライマリ出力はありません。
$ cd mnrechobot
$ dotnet run
テンプレートが生成する EchoBot.cs を確認
Bots/EchoBots.cs
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.
//
// Generated with EchoBot .NET Template version v4.17.1
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Bot.Builder;
using Microsoft.Bot.Schema;
namespace EchoBot.Bots
{
public class EchoBot : ActivityHandler
{
protected override async Task OnMessageActivityAsync(ITurnContext<IMessageActivity> turnContext, CancellationToken cancellationToken)
{
var replyText = $"Echo: {turnContext.Activity.Text}";
await turnContext.SendActivityAsync(MessageFactory.Text(replyText, replyText), cancellationToken);
}
protected override async Task OnMembersAddedAsync(IList<ChannelAccount> membersAdded, ITurnContext<IConversationUpdateActivity> turnContext, CancellationToken cancellationToken)
{
var welcomeText = "Hello and welcome!";
foreach (var member in membersAdded)
{
if (member.Id != turnContext.Activity.Recipient.Id)
{
await turnContext.SendActivityAsync(MessageFactory.Text(welcomeText, welcomeText), cancellationToken);
}
}
}
}
}
検証のために色々いじった EchoBots.cs
OpenAI の REST API に会話を送ったり、CosmosDB にチャット履歴を保存したり、チャット履歴をクリアしたりする機能を検証してみました。
dotnet add package Microsoft.Azure.Cosmos とかは必要に応じて。
Bots/EchoBots.cs
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.
//
// Generated with EchoBot .NET Template version v4.17.1
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Bot.Builder;
using Microsoft.Bot.Schema;
using System.Net.Http;
using System.Net.Http.Headers;
using System;
using System.Text.Json;
using System.Text;
using System.Net;
using Newtonsoft.Json.Linq;
using Microsoft.Azure.Cosmos;
namespace EchoBot.Bots
{
public class EchoBot : ActivityHandler
{
protected override async Task OnMessageActivityAsync(ITurnContext<IMessageActivity> turnContext, CancellationToken cancellationToken)
{
// デフォルトで返す値
var replyText = $"You Say: {turnContext.Activity.Text}";
// OpenAI の REST API 準備
HttpClient httpClient = new HttpClient();
httpClient.DefaultRequestHeaders.Add("Authorization", "Bearer " + Environment.GetEnvironmentVariable("OPENAI_API_KEY"));
JObject postData = JObject.Parse(@"{
""model"": ""gpt-3.5-turbo"",
""messages"": []
}");
JArray messages = (JArray)postData["messages"];
// CosmosDB 準備
var client = new CosmosClient(Environment.GetEnvironmentVariable("CDB_ENDPOINT"), Environment.GetEnvironmentVariable("CDB_KEY"));
var databaseResponse = await client.CreateDatabaseIfNotExistsAsync("chat");
var containerProperties = new ContainerProperties(turnContext.Activity.From.Id, "/id");
var containerResponse = await databaseResponse.Database.CreateContainerIfNotExistsAsync(containerProperties);
var database = client.GetDatabase("chat");
var container = database.GetContainer(turnContext.Activity.From.Id);
// チャット履歴を削除
if (turnContext.Activity.Text == "clear")
{
await container.DeleteContainerAsync();
containerResponse = await databaseResponse.Database.CreateContainerIfNotExistsAsync(containerProperties);
container = database.GetContainer(turnContext.Activity.From.Id);
await turnContext.SendActivityAsync(MessageFactory.Text("チャット履歴をクリアしました！", replyText), cancellationToken);
return;
}
// CosmosDB からチャット履歴を取得
var sqlQueryText = "SELECT * FROM c";
var queryDefinition = new QueryDefinition(sqlQueryText);
var results = container.GetItemQueryIterator<dynamic>(queryDefinition);
while (results.HasMoreResults)
{
var items = await results.ReadNextAsync();
foreach (var item in items)
{
// OpenAI のリクエストに追加
JObject history = new JObject();
history.Add("role", item["role"]);
history.Add("content", item["content"]);
messages.Add(history);
}
}
// OpenAI のリクエストの最後に今回のプロンプトを追加
JObject message = new JObject();
message.Add("role", "user");
message.Add("content", turnContext.Activity.Text);
messages.Add(message);
// OpenAI の REST API を実行
var post = postData.ToString();
var response = await httpClient.PostAsync("https://api.openai.com/v1/chat/completions",
new StringContent(post, Encoding.UTF8, "application/json"));
if (response.StatusCode == HttpStatusCode.OK)
{
// 実行結果のテキストを格納
replyText = "";
JObject completions = JObject.Parse(await response.Content.ReadAsStringAsync());
foreach (var value in completions.GetValue("choices"))
{
replyText += value["message"]?["content"];
}
// CosmosDB にチャット履歴を保存
var newItem = new {
id = Guid.NewGuid().ToString(),
role = "user",
content = turnContext.Activity.Text
};
await container.CreateItemAsync(newItem);
var addItem = new {
id = Guid.NewGuid().ToString(),
role = "assistant",
content = replyText
};
await container.CreateItemAsync(addItem);
}
// チャット返信
await turnContext.SendActivityAsync(MessageFactory.Text(replyText, replyText), cancellationToken);
}
protected override async Task OnMembersAddedAsync(IList<ChannelAccount> membersAdded, ITurnContext<IConversationUpdateActivity> turnContext, CancellationToken cancellationToken)
{
var welcomeText = "Hello and welcome!";
foreach (var member in membersAdded)
{
if (member.Id != turnContext.Activity.Recipient.Id)
{
await turnContext.SendActivityAsync(MessageFactory.Text(welcomeText, welcomeText), cancellationToken);
}
}
}
}
}
Teams でチャットしてる例
参考