Commit 9d84a4b3 authored by ZHOUYANG's avatar ZHOUYANG

压力测试图片和测试配置上传

parent 541dfabb
import flask
from flask import request, jsonify
from flask_cors import CORS
import json
import sys
app = flask.Flask(__name__)
CORS(app)
#@app.route('/dapr/subscribe', methods=['GET'])
#def subscribe():
# subscriptions = [{'pubsubname': 'pubsub',
# 'topic': 'deathStarStatus',
# 'route': 'dsstatus',
# 'metadata': {
# 'rawPayload': 'true',
# } }]
# return jsonify(subscriptions)
@app.route('/dsstatus', methods=['POST'])
def ds_subscriber():
print(request.json, flush=True)
return json.dumps('你好啊!'), 200, {'ContentType':'application/json'}
app.run(port=5001)
import flask
from flask import request, jsonify
from flask_cors import CORS
import json
import sys
app = flask.Flask(__name__)
CORS(app)
@app.route('/dsstatus', methods=['POST'])
def ds_subscriber():
print(request.json, flush=True)
return json.dumps({'success':True}), 200, {'ContentType':'application/json'}
app.run(port=5002)
import flask
from flask import request, jsonify
from flask_cors import CORS
import json
import sys
app = flask.Flask(__name__)
CORS(app)
@app.route('/dsstatus', methods=['POST'])
def ds_subscriber():
print(request.json, flush=True)
return json.dumps({'success':True}), 200, {'ContentType':'application/json'}
app.run(port=5004)
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: talents-database-rabbitmq-pubsub
namespace: default
spec:
type: pubsub.rabbitmq
version: v1
metadata:
- name: host
value: "amqp://admin:admin@localhost:5672"
# 是否使用durable队列, 默认值为 "false" 默认值为 "false"
- name: durable
value: "true"
# 是否将队列sohuld配置为自动删除默认设置为“true”
- name: deletedWhenUnused
value: "false"
# 队列的消费者是否应该auto-ack消息 默认值为 "false" 默认值为 "false"
- name: autoAck
value: "false"
# 发布消息时的持久化模式, 默认值为 "0". 值为"2"时RabbitMQ会进行持久化,其他值反之
- name: deliveryMode
value: "0"
# 在发送否定应答失败的情况下,是否进行重排, 默认值为 "false" 默认值为 "false"
- name: requeueInFailure
value: "false"
# prefecth的消息数量, 生产环境中需要考虑设置一个非零值。 生产环境中需要考虑设置一个非零值。 该值默认为"0",这意味着所有可用消息都将被预先提取
- name: prefetchCount
value: "0"
# 如果发生连接失败,在重新连接之前需要等待多长时间(秒)
- name: reconnectWait
value: "0"
# 默认值是parallel,表示允许并行处理多个消息(如果配置了app-max-concurrency,最大并行数会受到该值限制), 设置为single可禁用并行处理, 大多数情况下没必要去这么做 设置为single可禁用并行处理, 大多数情况下没必要去这么做
- name: concurrencyMode
value: parallel
#
- name: backOffPolicy
value: "exponential"
- name: backOffDuration
value: "5s"
- name: backOffInitialInterval
value: "100"
- name: backOffMaxInterval
value: "16"
- name: backOffMaxRetries
value: "16"
- name: backOffRandomizationFactor
value: "0.5"
- name: backOffMultiplier
value: "1.5"
- name: backOffMaxElapsedTime
value: "15m"
# 限制特定topic访问
# - name: allowedTopics
# value: "A,B"
# - name: publishingScopes
# value: "app1=A"
# - name: subscriptionScopes
# value: "app1=;app2=A"
apiVersion: dapr.io/v1alpha1
kind: Subscription
metadata:
name: talents-database-rabbitmq-subscription
spec:
# topic名称
topic: deathStarStatus
# 端点
route: /dsstatus
# 发布名称
pubsubname: talents-database-rabbitmq-pubsub
# metadata:
# rawPayload: "true"
# 指定app允许访问
scopes:
- app1
- app4
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment