1

我正在使用 AWS boto python 库。

我从 Jmeter 到我的 Web 应用程序的请求/秒达到 10000 个请求，该应用程序将数据写入 kinesis 流。我已经为 Stream 使用了 16 个 Shards。当我停止 Jmeter 时，我看到了一些未写入流的记录。我也有我的日志，但没有发现任何错误。这是我的示例代码

try:
       p_key = '{0}{1}'.format('partition_key',(1, 10000))

        # Connect to AWS Kinesis region
        kinesis_obj = kinesis.connect_to_region(region_name)

        # Put data on AWS Kinesis stream
        app.logger.debug(count++) 
        response = kinesis_obj.put_record(stream_name,record,p_key)
        app.logger.debug(count++)
        app.logger.debug(response)

except kinesis.exceptions.ResourceNotFoundException, re_ex:
    write_log(record, re_ex)

except kinesis.exceptions.ResourceInUseException, inuse_ex:        
    write_log(record, inuse_ex)

except Exception, ex:
    write_log(record, ex)

当我在这里打印计数时，收到了 25000 个请求。

response = kinesis_obj.put_record(stream_name,record,p_key)

而且，我在这里收到了 24900 个请求。

100 条缺失记录。

response无一例外都没有回应。

4

0 回答 0