如何将 websockets 数据保存到数据库

Question

我想阅读这个流：wss://stream.binance.com:9443/ws/btcusdt@trade 并将数据保存到数据库以便我以后可以使用它。

我不知道如何或在哪里调用该函数，因为它是连续的数据流，我不知道如何处理它。

我正在使用这个 php 库：

https://github.com/jaggedsoft/php-binance-api

更具体的代码：

$api->trades(["BNBBTC"], function($api, $symbol, $trades) {
    echo "{$symbol} trades update".PHP_EOL;
    print_r($trades);
});

我知道如何将数据保存到db，但我不知道如何调用函数。

public function x(){
$api = new API("api", "secret";
$api->trades(["BTCUSDT"], function($api, $symbol, $trades) {
            $data = new BinanceData();
            $data->symbol = $symbol;
            $data->price = $trades['price'];
            $data->binance_timestamps = $trades['timestamp'];
            $data->maker = $trades['maker'];
            $data->quantity = $trades['quantity'];
            $data->save();
        });
}

我访问/x路由的时候直接调用这个函数：

Route::get('/x', [BinanceController::class, 'x']);

问题是如何在 Laravel 的后台调用这个函数，这样我就不必访问任何路由或任何东西。

谢谢

Answer 1

创建一个 laravel artisan 命令，在内核中注册。然后使用 linux 上的 supervisor 或任何进程管理器来不断调用它来创建一个守护进程

https://laravel.com/docs/8.x/artisan