无法在AWS EC2上向kafka发送消息，来自用AWS Lambda函数编写的生产者

Question

冲突Kafka 5.0.0已安装在AWS EC2上，它有公共IP，比如54.XX.XX.XX在EC2机器上打开端口9092，0.0.0.0

在 /etc/kafka/server.properties我有advertised.listeners=PLAINTEXT：//54.XX.XX.XX:9092和侦听器=PLAINTEXT：//0.0.0.0:9092在 /etc/kafka/producer.properties我有bootstrap.servers=0.0.0.0:9092

本地文件iotstatesboto.py如下所述，它具有融合的生产者代码：

from confluent_kafka import Producer
import json

broker = '54.XX.XX.XX'
topic = 'mytopic'

def delivery_report(err, msg):
    if err is not None:
        print('Message delivery failed: {}'.format(err))
    else:
        print('Message delivered to {}'.format(msg.topic()))

def lambda_handler(event, context): 
    p = Producer({'bootstrap.servers': broker})
    message = json.dumps(event)
    print(message)
    p.produce(topic, message.encode('utf-8'), callback=delivery_report)
    return { 
        'message' : message
    }  

zip包在本地制作，如下所示:

pip install confluent_html" target="_blank">kafka has been done in the same directory
zip -r iotstatesboto.zip iotstatesboto.py confluent*

此zip文件上载到Lambda函数。然后，当“Test”函数发送一条虚拟消息时，出现以下错误

第一：

{
  "errorMessage": "Unable to import module 'iotstatesboto'"
}

还有一个是：

Unable to import module 'iotstatesboto': No module named 'confluent_kafka.cimpl'

我已经将处理程序名设置为“iotstatesboto.lambda _ handler”

要让生产者从lambda函数写入EC2上的kakfa流，这些步骤中可能缺少什么线索？

Answer 1

使用AWS Lambda时，您必须手动提供所有库，即将它们添加到您用于lambda函数代码的zip中。如果有的话，您还必须添加所有共享对象库。

在本例中，AWS Lambda为您提供了由python标准库Boto3组成的python环境，因此没有其他库。