个人中心
gpt4 book ai didi

python-2.7 - 我需要将一个服务器 app.py 中的 json 数据发送到另一个服务器 app.py 服务？

转载 作者：可可西里 更新时间：2023-11-01 11:48:08 28 4
gpt4 key购买 nike

下面的服务有 json 数据。数据是从 mongodb 获取的。

@app.route('/notifications',methods = ['GET', 'POST'])
def notifications():
    detailes = Notifications.objects()
    dt=[]
   for i in detailes:
       data={}
       data['usertype'] = i.usertype
       data['user_id'] = i.user_id
       data['date_time'] = i.date_time
       data['message'] = i.message
       data['title'] = i.title
       data['status'] = i.status
       data['last_notification_time'] = i.last_notification_time
       json_data = json.dumps(data)
       test=json.loads(json_data)
       dt.append(test)
    return jsonify(dt)

现在我需要将这个最终的 json 数据发送到另一个服务器和另一个 app.py 中的另一个服务。下面是我的代码。

from flask import Flask, render_template,request
from flask_sse import sse

 app = Flask(__name__)
 app.config["REDIS_URL"] = "redis://localhost"
 app.register_blueprint(sse, url_prefix='/stream')

 @app.route('/')
 def index():
     return render_template("index.html")

 @app.route('/hello')
 def publish_hello():
     sse.publish({"message": "Hello!"}, type='greeting')
    return "Message sent!"

我需要传递变量“dt”中的 json_data 来代替 hello 服务中的 message [sse.publish({"message": "Hello!"}, type='greeting')]。

最佳答案

只需将 dt 注入(inject)传递给客户端的字典。 

def some_function_that_grabs_messages():
    return some_data

@app.route('/hello')
def publish_hello():
    dt - some_function_that_grabs_messages():
    sse.publish({"message": dt}, type='greeting')
    return "Message sent!"

更新:

sse.py

from flask import Flask, render_template
from flask_sse import sse
import pymysql as mysql

app = Flask(__name__)
app.config["REDIS_URL"] = "redis://localhost"
app.register_blueprint(sse, url_prefix='/stream')

def conn_handler():
    conn = mysql.connect(host='localhost', user='root', password='123456', database='feedparser', charset='utf8mb4')
    cur = conn.cursor()
    cur.execute("SELECT title FROM articles WHERE id < 30")
    data = cur.fetchall()  
    conn.close()
    return data

@app.route('/')
def index():
    return render_template("index.html")

@app.route('/hello')
def publish_hello():
    data = conn_handler()
    for title in data:
      sse.publish({"message": title[0]}, type='greeting')

    return "Message sent!"

templates/index.html

<!DOCTYPE html>
<html>
<head>
  <title>Flask-SSE Quickstart</title>
</head>
<body>
  <h1>Flask-SSE Quickstart</h1>
  <script>
    var source = new EventSource("{{ url_for('sse.stream') }}");
    source.addEventListener('greeting', function(event) {
        var data = JSON.parse(event.data);
        document.getElementById("messages").innerHTML += data.message+"<br />";
    }, false);
    source.addEventListener('error', function(event) {
        alert("Failed to connect to event stream. Is Redis running?");
    }, false);
  </script>
</body>
<div id="messages">

</div>
</html>

运行

$ gunicorn sse:app --worker-class gevent --bind localhost:8000

关于python-2.7 - 我需要将一个服务器 app.py 中的 json 数据发送到另一个服务器 app.py 服务？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/46729479/

28 4 0
文章推荐： authentication - 如何使用redis作为mosquitto ACL的后端
文章推荐： windows - nmake:构建 OpenSSL 时找不到命令
文章推荐： windows - 是否存在函数 CreateFile 返回 INVALID_HANDLE_VALUE 而 GetLastError() 返回 ERROR_ALREADY_EXISTS 的情况
文章推荐： Azure Redis 缓存主机
可可西里
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com