如何使用Redis和PowerShell开发分布式任务调度功能

$timestamp = [DateTime]::Now.Ticks
$taskId = "task1"
$redisCmd = "ZADD task_queue $timestamp $taskId"
Invoke-Expression -Command $redisCmd

$redisCmd = "SUBSCRIBE task_channel"
Invoke-Expression -Command $redisCmd

$taskId = "task1"
$redisCmd = "ZREM task_queue $taskId"
Invoke-Expression -Command $redisCmd

Install-Module -Name StackExchange.Redis -AllowPrerelease

$redis = [StackExchange.Redis.ConnectionMultiplexer]::Connect("localhost:6379")

$redisDb = $redis.GetDatabase()
$redisDb.StringSet("key", "value")
$value = $redisDb.StringGet("key")
$redisDb.SortedSetAdd("task_queue", $timestamp, $taskId)
$redisDb.SortedSetRemove("task_queue", $taskId)

$redis = [StackExchange.Redis.ConnectionMultiplexer]::Connect("localhost:6379")
$redisDb = $redis.GetDatabase()

function AddTaskToQueue($taskId) {
    $timestamp = [DateTime]::Now.Ticks
    $redisDb.SortedSetAdd("task_queue", $timestamp, $taskId)
}

$taskChannel = $redis.GetSubscriber().Subscribe("task_channel")
$taskChannel.OnMessage({ 
    $taskId = $_.Message
    # 执行任务操作
    Write-Host "Task $taskId is executing..."
    Start-Sleep -Seconds 5
    # 移除任务
    $redisDb.SortedSetRemove("task_queue", $taskId)
    Write-Host "Task $taskId is completed."
})

# 添加任务到队列
AddTaskToQueue("task1")
AddTaskToQueue("task2")