步骤：

二、【kafka生产者脚本封装】案例实现：

1、编写前端平台代码。react语言

2、搭建后端服务(flask轻便)，编写服务端代码，封装脚本为接口调用方式，postman调试接口请求OK，达到预期效果。python实现。

注意事项：1）服务端的端口号不与前端 及平台的其他服务重复。

3、前后端联调。

方法：

1）前端调用时，后端服务加调试代码，保证postman传入的参数 与前端传入的参数格式 给接口的是一致的。

2）前端鼠标右键 【检查】可看到 前后端参数传递情况。

注意事项：

1）前后端传入的参数大小写需一致，不然可能拿到的是None。

4、用户使用方便，兼容场景。考虑异常情况。

二、实现

flask启动脚本：

import flask,json,time from flask import request import asyncio from aiokafka import AIOKafkaProducer from kafkproducer import send_one loop = asyncio.get_event_loop() app = flask.Flask(__name__) @app.route('/kafka_producer', methods=['POST']) def index(): json_data = json.loads(request.get_data().decode('utf-8')) Topic = json_data.get("Topic") KafkaData = json_data.get("KafkaData") KafkaCount = json_data.get("KafkaCount") KafkaCluster = json_data.get("KafkaCluster") #调试使用 # print("topic=",Topic) # print("KafkaData=",KafkaData) # print("KafkaCount=",KafkaCount) # print("KafkaCluster=",KafkaCluster) if Topic and KafkaData and KafkaCount and KafkaCluster: res={"msg":"接口调用成功","msg_code":"0000"} loop.run_until_complete(send_one(Topic,KafkaData,KafkaCount,KafkaCluster)) return json.dumps(res, ensure_ascii=False) else: res={"msg":"接口调用失败，必填项为空","msg_code":"9999"} return json.dumps(res, ensure_ascii=False) if __name__ == '__main__': # app.run() app.run(port=1111,debug=True,host='0.0.0.0')

kafka生产者脚本：

import asyncio import json,time from aiokafka import AIOKafkaProducer loop = asyncio.get_event_loop() now = int(time.time()) async def send_one(Topic,KafkaData,KafkaCount,KafkaCluster): producer = AIOKafkaProducer( bootstrap_servers=KafkaCluster) await producer.start() try: for i in range(KafkaCount): data = { "msg_type": 20, "context": json.dumps(KafkaData), "enqueue_time": now, } await producer.send_and_wait(Topic, json.dumps(data).encode()) except Exception as e: print(e) finally: await producer.stop() print(json.dumps(data))

3、flask服务搭建

mkdir 项目名称

cd 项目名称

$ python3 -m venv venv $ . venv/bin/activate $ pip install Flask

注意最后一步 是在上一步venv启动后实现的

---

1.本站遵循行业规范，任何转载的稿件都会明确标注作者和来源；2.本站的原创文章，会注明原创字样,如未注明都非原创，如有侵权请联系删除！；3.作者投稿可能会经我们编辑修改或补充；4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。