使用 Pulsetracker、Laravel 和 Python 构建实时位置跟踪解决方案

简介：什么是 PulseTracker？

Pulsetracker 是一种用于实时位置跟踪的后端服务，专为需要强大而灵活的方式来监控位置数据而无需依赖专有 SDK 或基础设施的开发人员而设计。它允许开发人员使用 UDP 或 WebSocket 协议实现自己的客户端 SDK。此外，Pulsetracker 可以直接向开发者后端发送实时位置更新，使其成为需要实时跟踪的应用程序的强大选择。

在本教程中，我们将逐步使用 Pulsetracker 和 Python 脚本作为实时位置更新的监听器。 Python 脚本充当 Pulsetracker 监听器，接收更新并通过 Redis 将它们分派给 Laravel 作业处理程序，使 Laravel 能够高效地处理这些更新。

先决条件

1.Pulsetracker 帐户：设置 Pulsetracker 帐户并获取您的应用程序密钥和授权令牌。

2.Redis：确保您已安装并运行 Redis。

3.Laravel 项目：如果您还没有 Laravel 项目，请建立一个。

项目设置

此设置涉及两个主要组件：

1.Python 脚本：监听来自 Pulsetracker 的位置更新。

2.Laravel Job：处理从Python脚本接收到的位置数据。

第 1 步：设置 Python 脚本

Python 脚本连接到 Pulsetracker 的 Pusher 服务，监听位置更新，并将它们推送到 Redis 队列中供 Laravel 处理。

#!/usr/bin/env python

import sys
sys.path.append('..')
import pysher
import time
import logging
import redis
import json 
import uuid

global pusher
global redis

def channel_callback(data):
    messageBody = json.dumps({
        "uuid": str(uuid.uuid4()),
        "displayName": "App\Jobs\PulseLocationUpdatedJob",
        "job": "App\Jobs\PulseLocationUpdatedJob@handle",
        "data": json.loads(data),
        "maxTries": 0,
        "attempts": 0
    })
    # YOUR_APP_NAME_database_queues:QUEUE_NAME
    redis.rpush("pulsetracker_database_queues:geopulse", messageBody)

def connect_handler(data):
    channel = pusher.subscribe("private-apps.<your_app_id>")
    channel.bind('App\Events\DeviceLocationUpdated', channel_callback)

if __name__ == '__main__':

    appkey = "<pusher_app_key_in_our_documentation>"
    auth_endpoint = "https://www.pulsestracker.com/api/broadcasting/auth"

    pusher = pysher.Pusher(
        key=appkey,
        auth_endpoint_headers={            
                "Authorization": "Bearer <your_token>"
        },
        auth_endpoint=auth_endpoint,
        custom_host="pusher.pulsestracker.com",
        secure=True,
    )

    redis = redis.Redis(host='127.0.0.1', port=6379, db=0, password="<your_redis_password>")

    pusher.connection.ping_interval = 30
    pusher.connect()

    pusher.connection.bind('pusher:connection_established', connect_handler)

    while True:
        time.sleep(1)

在此脚本中：

channel_callback 函数将位置更新推送到 Redis 队列中。

connect_handler 函数订阅特定的 Pulsetracker 通道并将其绑定到 DeviceLocationUpdated 事件。

此脚本应该持续运行以侦听更新并将其传递给 Laravel 的 Redis

第 2 步：配置 Laravel

现在，让我们创建一个 Laravel 作业类来处理从 Python 脚本收到的更新。

Laravel 作业：PulseLocationUpdatedJob

在 Laravel 中，作业类处理由 Python 监听器推送到 Redis 队列的数据。这是 PulseLocationUpdatedJob 类：

<?php

namespace App\Jobs;

use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;

class PulseLocationUpdatedJob implements ShouldQueue
{
    use Queueable;

    /**
     * Create a new job instance.
     */
    public function __construct()
    {
        //
    }

    /**
     * Execute the job.
     */
    public function handle($job, array $data)
    {
        // Handle the data here, e.g., save to the database
        var_dump($data);

        return $job->delete();
    }
}

启动 Laravel 队列工作程序以开始处理作业：

php artisan queue:work --queue=geopulse

结果

结论

在此设置中，Python 侦听器有效地将实时位置数据从 Pulsetracker 流式传输到 Redis 队列，Laravel 将其作为后台作业进行处理。这种方法使您能够处理大量实时数据，同时让 Laravel 专注于数据持久性和后端任务。

资源：
https://fly.io/laravel-bytes/queues-with-other-languages/

以上是使用 Pulsetracker、Laravel 和 Python 构建实时位置跟踪解决方案的详细内容。更多信息请关注PHP中文网其他相关文章！