Goで書く！無限の堅牢ワークフロー！🚀

概要：なにこれ凄い？

うおおお！皆さん、聞いてくださいよ！僕、普段からマイクロサービスとか分散システムを触る機会が多いんですけど、複雑なビジネスロジックって、途中でプロセス落ちたり、ネットワークエラーになったりすると、もう本当に地獄じゃないですか？どこから再開すればいいのか、状態はどうなってるのか…考えるだけで胃がキリキリするんですよ。でもね、このTemporal、そんな悩みを根本から解決してくれるんです！最初に見た時、『え、これ魔法？』って本気で思いましたもん！だって、ワークフローを普通のコードで書いてるのに、プロセスが落ちても、サーバーが再起動しても、何事もなかったかのように続きから実行してくれるんですよ！これって、もはや夢ですよね？Goで書かれたこのCore Serviceが、その驚異的な堅牢性を支えてるんだって思うと、ゾクゾクしちゃいます！

ここが推し！

• まるで魔法！プロセスを超越するワークフロー: 普通のGoの関数としてワークフローを記述できるのに、途中でサーバーがクラッシュしても、ネットワークが途切れても、Temporalが賢く状態を保持して、何事もなかったかのように再開してくれるんです！これ、本当に感動レベルですよ！
• 複雑なビジネスロジックも怖くない！: 何段階にもわたる処理、タイムアウト後のリトライ、人間による承認を待つ長時間タスク…これら全部、普通のGoコードでシンプルに書けちゃうんです。複雑なステート管理やエラーハンドリングを自分でゴリゴリ書く必要がないなんて、エンジニアの夢じゃないですか？
• 圧倒的なスケーラビリティと信頼性: Core ServiceがGoで書かれているだけあって、パフォーマンスと安定性は折り紙つき！数百万のワークフローを同時に動かしてもビクともしない設計になってるんです。ミッションクリティカルなシステムでも安心して導入できますよね！

サクッと試そう（使用例）

package main

import (
	"context"
	"fmt"
	"log"
	"time"

	"go.temporal.io/sdk/client"
	"go.temporal.io/sdk/worker"
	"go.temporal.io/sdk/workflow"
)

// Activity
func GreetActivity(ctx context.Context, name string) (string, error) {
	log.Printf("Activity: Greeting %s\n", name)
	time.Sleep(time.Second * 2) // Simulate some work
	return fmt.Sprintf("Hello, %s!", name), nil
}

// Workflow
func MyWorkflow(ctx workflow.Context, name string) (string, error) {
	ao := workflow.ActivityOptions{
		StartToCloseTimeout: time.Second * 5,
	}
	ctx = workflow.WithActivityOptions(ctx, ao)

	var result string
	err := workflow.ExecuteActivity(ctx, GreetActivity, name).Get(ctx, &result)
	if err != nil {
		return "", err
	}
	return result, nil
}

func main() {
	// Local Temporal server (temporalite)が必要！
	// まずは `go install go.temporal.io/temporalite@latest` でインストールして
	// `temporalite start --ephemeral` で起動してみてね！

	c, err := client.Dial(client.Options{})
	if err != nil {
		log.Fatalln("Unable to create client", err)
	}
	defer c.Close()

	w := worker.New(c, "my-task-queue", worker.Options{})
	w.RegisterWorkflow(MyWorkflow)
	w.RegisterActivity(GreetActivity)

	go func() {
		err = w.Run(worker.InterruptCh())
		if err != nil {
			log.Fatalln("Unable to start worker", err)
		}
	}()

	// Start a workflow
	options := client.StartWorkflowOptions{
		ID:        "greet-workflow-id",
		TaskQueue: "my-task-queue",
	}
	we, err := c.ExecuteWorkflow(context.Background(), options, MyWorkflow, "Akira")
	if err != nil {
		log.Fatalln("Unable to execute workflow", err)
	}
	log.Printf("Started workflow: %s %s\n", we.GetID(), we.GetRunID())

	// Get workflow result
	var result string
	err = we.Get(context.Background(), &result)
	if err != nil {
		log.Fatalln("Unable to get workflow result", err)
	}
	log.Println("Workflow result:", result)

	log.Println("Worker is running. Press Ctrl+C to stop.")
	select {} // Keep main goroutine alive
}

ぶっちゃけ誰向け？

• 複雑な分散システムと格闘中のあなた: マイクロサービス間の連携でエラーハンドリングやリトライロジックを自前で実装して疲弊してるなら、Temporalがあなたの救世主になりますよ！マジで！
• 安定したバッチ処理や長時間処理を求めるあなた: 数時間、数日にわたるような処理で、途中で落ちても大丈夫な堅牢なシステムを構築したいなら、Temporalはまさにうってつけ！心配事から解放されちゃいます。
• ビジネスロジックに集中したいGoエンジニアのあなた: インフラの複雑な管理や分散システムの悩みをTemporalに任せて、ひたすらビジネス価値を生み出すコードを書きたい！そんなあなたに、僕は全力でTemporalをおすすめしますね！

まとめ

どうでしたか皆さん？Temporalio/Temporalの魅力、ちょっとは伝わりましたかね？正直、導入にはTemporal Serverのセットアップが必要だったりして、少しだけ学習コストはあるかもしれません。でもね、それを乗り越えた先に待っているのは、圧倒的に堅牢で、圧倒的に開発しやすい分散システムの世界ですよ！これからの僕らの開発が、もっともっと楽しく、そして生産的になること間違いなし！ぜひ一度、触ってみてほしいなぁ！未来のシステム開発は、もうTemporal抜きには語れない！って、僕、本気で思ってますからね！