使用不同的redis連接處理Laravel中的作業(yè)

我有一個系統(tǒng),在這個系統(tǒng)中,我每小時都會啟動大量的作業(yè),我希望它們在不同的redis連接上處理,與彈出的主要作業(yè)分開,這樣它們就不會干擾推到隊列中的其他作業(yè)(即延遲作業(yè))。

因此,我做了以下工作,創(chuàng)建了一個新的redis連接:

    'kingdom_jobs' => [
        'url' => env('REDIS_URL'),
        'host' => env('REDIS_HOST', '127.0.0.1'),
        'password' => env('REDIS_PASSWORD', null),
        'port' => env('REDIS_PORT', 6379),
        'database' => env('REDIS_CACHE_DB', 2),
    ],

然后創(chuàng)建了一個新的隊列連接:

    'kingdom_jobs' => [
        'driver' => 'redis',
        'connection' => 'kingdom_jobs', // Uses the new connection
        'queue' => env('REDIS_QUEUE', 'default'),
        'retry_after' => 90,
        'block_for' => null,
    ],

然后在旋轉(zhuǎn)所有這些作業(yè)的循環(huán)中:

    Kingdom::chunkById(250, function($kingdoms) use ($service) {
        foreach ($kingdoms as $kingdom) {
            UpdateKingdomJob::dispatch($kingdom)->onConnection('kingdom_jobs');
        }
    });

The issue?

是的,他們被推到了這個新的連接上,我在地平線上看到他們——超過500個——但他們什么也沒做。它們不會被處理。有沒有辦法告訴horizon處理這個附加連接?

我目前在開發(fā)中使用php artisan horizon來處理作業(yè)-還有其他步驟嗎?

我假設(shè)從文檔中,我遺漏了一些步驟,我假設(shè)它與文檔中的php artisan queue:work --tries = 3有關(guān)?試著那樣做沒用。我是否需要此新連接的另一個horizon實例,或者我是否配置horizon以了解此連接?

Help?

? 最佳回答:

很可能您沒有Horizon supervisor設(shè)置來監(jiān)視新隊列。

查看地平線配置:

'environments' => [
    'production' => [
        'supervisor-1' => [
            'connection' => 'redis',
            'queue' => ['default'],
            'balance' => 'auto',
            'minProcesses' => 1,
            'maxProcesses' => 10,
            'balanceMaxShift' => 1,
            'balanceCooldown' => 3,
            'tries' => 3,
        ],
    ],
],

看起來我們可以向生產(chǎn)環(huán)境添加另一個主管(如果需要,還可以添加其他主管):

'environments' => [
    'production' => [
        'supervisor-1' => [
            'connection' => 'redis',
            'queue' => ['default'],
            'balance' => 'auto',
            'minProcesses' => 1,
            'maxProcesses' => 10,
            'balanceMaxShift' => 1,
            'balanceCooldown' => 3,
            'tries' => 3,
        ],
        'supervisor-2' => [
            'connection' => 'kingdom_jobs',
            'queue' => ['default'],
            'balance' => 'auto',
            'minProcesses' => 1,
            'maxProcesses' => 10,
            'balanceMaxShift' => 1,
            'balanceCooldown' => 3,
            'tries' => 3,
        ],
    ],
],
主站蜘蛛池模板: 日韩精品人妻av一区二区三区| 岛国无码av不卡一区二区| 日韩AV无码一区二区三区不卡| 国产伦精品一区二区三区免费下载| 久久亚洲综合色一区二区三区| 国产成人一区二区在线不卡| 日韩美女视频一区| 亚洲综合一区二区精品导航| 天天爽夜夜爽人人爽一区二区| 无码中文字幕乱码一区| 亚洲一区二区电影| 久久精品岛国av一区二区无码| 亚洲AV无码一区二区三区在线观看 | 亚洲AV日韩精品一区二区三区| 精产国品一区二区三产区| 国产精品香蕉在线一区| 亚洲日本va午夜中文字幕一区| 东京热人妻无码一区二区av| av无码人妻一区二区三区牛牛 | 精品人妻中文av一区二区三区| 日韩精品无码一区二区视频| 香蕉一区二区三区观| 国产精品 视频一区 二区三区| 一区二区三区四区国产| 亚洲AV成人精品日韩一区18p | 久久精品人妻一区二区三区| 无码精品人妻一区二区三区AV| 国产在线一区二区三区av| 精品女同一区二区| 一区免费在线观看| 国模精品一区二区三区| 人成精品视频三区二区一区| 四虎永久在线精品免费一区二区| 国产福利一区视频| av无码一区二区三区| 亚洲乱码国产一区三区| 在线播放国产一区二区三区| 亚洲一区二区三区乱码在线欧洲| 亚洲av乱码中文一区二区三区| 无码一区二区三区爆白浆| 大香伊蕉日本一区二区|