curl -XPOST 'http://127.0.0.1:8000/tag/create' \
-H 'content-type:application/json' \
-d '{"tag":"php"}'

from rest_framework.decorators import api_view
from rest_framework.response import Response

@api_view(["POST"])
def tag_create(request):
    print(request.data)
    tag = request.data.get('tag')

server{
    server_name domain;
    root /var/www/html;
    location / {
        proxy_pass http://127.0.0.1:8080;
        proxy_set_header host $host;
        proxy_set_header X-real-ip $remote_addr;
        proxy_set_header X-forward-for $proxy_add_x_forwarded_for;
    }
}

sleep一段时间

var sleep = async function (ms) {
            return new Promise(function (resolve) {
                setTimeout(resolve, ms);
            });
        };

使用

for (var i = 0; i < 10; i++) {
            console.log(i, Date.now());
            await sleep(2000);
        }

Math.random()

安装kafka-python

pip install kafka-python

代码

from kafka import KafkaConsumer, TopicPartition

bootstrap_servers = ['localhost:9092']
topic = 'test'
group_id = 'lll'

consumer = KafkaConsumer(
    group_id="my-group",
    bootstrap_servers=bootstrap_servers,
    auto_offset_reset='latest'
)

PARTITIONS = []
for partition in consumer.partitions_for_topic(topic):
    PARTITIONS.append(TopicPartition(topic, partition))

end_offsets = consumer.end_offsets(PARTITIONS)
print(end_offsets)

#输出
#{TopicPartition(topic='test', partition=2): 354915,
#TopicPartition(topic='test', partition=1): 354926,
#TopicPartition(topic='test', partition=0): 354892}