python - 将数据从 Django 发送到另一台服务器

Question

我已有一个 Django 应用程序。我想添加一个系统，将数据从我的 Django 应用程序发送到另一台服务器上托管的另一个 Python 应用程序，以便 Python 应用程序可能以 json 格式从 Django 应用程序接收数据。

因此，例如，我需要创建一个 View ，每隔几秒钟将数据从数据库表发送到此应用程序，或者当表单被点击时，数据被发送到此外部应用程序。

我该怎么做？是否有针对此特定问题的示例？我不知道我需要使用什么工具来创建这个系统，我只知道我需要使用 Celery 来执行异步任务，但仅此而已；我应该使用 Webhooks 吗？还是 Django channel ？

编辑:添加更多上下文:我有我的 Django 客户端。然后我有一个或两个 Python 应用程序在另一台服务器上运行。在我的 Django 客户端上，我有一些表格。提交表单后，数据将保存在数据库中，但我也希望将这些数据立即发送到我的 Python 应用程序。 Python 应用程序应该从 Django 接收 Json 格式的数据，并根据用户提交的值执行一些任务。然后应用程序应向 Django 发送响应。

Answer 1

加油!我将在此处将你的 Django 应用程序称为 “DjangoApp”，将你的 Python 应用程序称为 Flask 或 “OtherApp” 的其他框架。

首先，正如您预测的那样，您需要一个能够执行g 任务的框架，新的 **Django 3.0 允许这样做，但我还没有使用然而...我将向您传递一些您正在使用的并且在 Django 2.8 和 Python 3.8 中功能齐全的东西**。

在您的 DjangoApp 服务器上，您需要构建与 Celery 的良好通信，让我们将任务留给他。你可以阅读Celery Docs和 this post , 做这个架构很ok。

无论你的表单或Django App看起来如何，当你想让它在celery中激活一个任务时，它基本上是传输数据的功能，但在后台。

from .tasks import send_data

...
form.save()
# Create a function within the form to get the data the way you want it
# or do it the way you want.
values = form.new_function_serializedata()
send_data.delay(values) # [CALL CELERY TASKS][1]
...

也读CALL CELERY TASKS

在所有其他应用程序中，您将需要一个 POST 路由来接收和序列化这些数据，使用像 Pyramid 这样的轻量级框架来做到这一点。

这样，每次提交表单时，您都会在 send_data 函数中将此数据发送到服务器。

根据我的经验，但不太了解您的问题，我会使用类似的架构，但使用 Celery Beat .

CELERY_BEAT_SCHEDULE = {
    'send_data': {
        'task': 'your_app.tasks.send_data',
        'schedule': crontab(), # CONFIGURE YOUR CRON
    },
}

不但加了上面的代码，还差不多的样子。

在您的模型中，我会为已发送 创建一个字段。并且每 2 秒、10 秒 .. 只要我希望我会使用 sent = false 过滤所有对象，并为 send_data 任务传递所有对象。

我不知道你是否感到困惑，要解释的东西太多了。但我希望我能帮助并回答您的问题。