Microservices Engine:Java、Go、または Python アプリケーションをビルドし、XXL-JOB に接続する

Java

Golang

1. 環境の構成: 次のコマンドを実行して、最新のタグを使用して Go バージョンの XXL-JOB ソフトウェア開発キット (SDK) をプルします。特定のバージョンについては、「xxl-job-executor-go」をご参照ください。

   go get github.com/xxl-job/xxl-job-executor-go@{latest_tag}

2. エグゼキュータ初期化コードを記述します。

   package main
   
   import (
       "context"
       "fmt"
       xxl "github.com/xxl-job/xxl-job-executor-go"
       "github.com/xxl-job/xxl-job-executor-go/example/task"
       "log"
   )
   
   func main() {
       exec := xxl.NewExecutor(
           xxl.ServerAddr("xxxxxx"),       // リクエストアドレス。コンソールの接続構成から取得します。
           xxl.AccessToken("xxxxxxx"),     // リクエストトークン。コンソールの接続構成から取得します。
           xxl.ExecutorPort("9999"),       // デフォルト: 9999。このパラメーターはオプションです。
           xxl.RegistryKey("golang-jobs"), // エグゼキュータの名前。
           xxl.SetLogger(&logger{}),       // カスタムロガー。
       )
       exec.Init()
       exec.Use(customMiddleware)
       // ログ表示ハンドラを設定します。
       exec.LogHandler(customLogHandle)
       // ジョブハンドラを登録します。
       exec.RegTask("task.test", task.Test)
       exec.RegTask("task.shardingTest", task.ShardingTest)
       log.Fatal(exec.Run())
   }
   
   // カスタムログハンドラ。
   func customLogHandle(req *xxl.LogReq) *xxl.LogRes {
       return &xxl.LogRes{Code: xxl.SuccessCode, Msg: "", Content: xxl.LogResContent{
           FromLineNum: req.FromLineNum,
           ToLineNum:   2,
           LogContent:  "This is a custom log handler",
           IsEnd:       true,
       }}
   }
   
   // xxl.Logger インターフェイスの実装。
   type logger struct{}
   
   func (l *logger) Info(format string, a ...interface{}) {
       fmt.Println(fmt.Sprintf("Custom log - "+format, a...))
   }
   
   func (l *logger) Error(format string, a ...interface{}) {
       log.Println(fmt.Sprintf("Custom log - "+format, a...))
   }
   
   // カスタムミドルウェア。
   func customMiddleware(tf xxl.TaskFunc) xxl.TaskFunc {
       return func(cxt context.Context, param *xxl.RunReq) string {
           log.Println("I am a middleware start")
           res := tf(cxt, param)
           log.Println("I am a middleware end")
           return res
       }
   }

3. ジョブ実行コードを記述します。

   package task
   
   import (
   	"context"
   	"fmt"
   	xxl "github.com/xxl-job/xxl-job-executor-go"
   )
   
   func Test(cxt context.Context, param *xxl.RunReq) (msg string) {
   	fmt.Println("test one task" + param.ExecutorHandler + " param: " + param.ExecutorParams + " log_id:" + xxl.Int64ToStr(param.LogID))
   	return "test done"
   }
   
   func ShardingTest(cxt context.Context, param *xxl.RunReq) (msg string) {
   	fmt.Println("shardingId:" + xxl.Int64ToStr(param.BroadcastIndex) + ", shardingTotal:" + xxl.Int64ToStr(param.BroadcastTotal))
   	return "ShardingTest done"
   }

Python

1. 依存関係をプルします。特定のバージョンについては、「xxl-job-executor-python」をご参照ください。

   pip install pyxxl
   
   # ログを Redis に書き込む必要がある場合
   pip install "pyxxl[redis]"
   
   # .env から構成をロードする場合
   pip install "pyxxl[dotenv]"
   
   # すべての機能をインストール
   pip install "pyxxl[all]"

2. ジョブ実行コードを記述します。

   import asyncio
   import time
   
   from pyxxl import ExecutorConfig, PyxxlRunner
   from pyxxl.ctx import g
   
   config = ExecutorConfig(
       xxl_admin_baseurl="http://xxljob-1b3fd81****.schedulerx.mse.aliyuncs.com/api/",
       executor_app_name="xueren-test",
       access_token="default_token",
       # xxl-admin がエグゼキュータの IP に直接接続できる場合、executor_listen_host を入力する必要はありません
   )
   
   app = PyxxlRunner(config)
   
   
   @app.register(name="demoJobHandler")
   async def test_task():
       # "g" を使用してジョブパラメーターを取得できます
       g.logger.info("get executor params: %s" % g.xxl_run_data.executorParams)
       for i in range(10):
           g.logger.warning("test logger %s" % i)
       await asyncio.sleep(5)
       return "Success..."
   
   @app.register(name="sync_func")
   def test_task4():
       # xxl-admin で実行ログを表示するには、g.logger を使用して出力する必要があります。デフォルトでは、INFO レベル以上のログのみが出力されます。
       n = 1
       g.logger.info("Job %s get executor params: %s" % (g.xxl_run_data.jobId, g.xxl_run_data.executorParams))
       # 同期ジョブにループが含まれている場合は、キャンセル操作をサポートするために、各反復で g.cancel_event をチェックする必要があります。
       while n <= 10 and not g.cancel_event.is_set():
           # xxl-admin からログを表示する必要がない場合は、独自のロガーを使用できます。
           g.logger.info(
               "log to {} logger test_task4.{},params:{}".format(
                   g.xxl_run_data.jobId,
                   n,
                   g.xxl_run_data.executorParams,
               )
           )
           time.sleep(2)
           n += 1
       return "Success 3"
   
   
   if __name__ == "__main__":
       app.run_executor()