Trigger Lambda Execution on DB Record Update (Part 1)
内容提要
本文介绍了一种多个子系统之间实现数据同步的架构，使用审计日志和Amazon CloudWatch触发AWS Lambda函数，简单可靠。同时介绍了使用Kinesis Data Streams处理Lambda函数错误和控制并发执行数的方法。给出了使用C#实现Kinesis DataStream数据处理的示例代码。
延伸解读
架构选择：审计日志触发与Kinesis的权衡
文章指出，使用审计日志和CloudWatch触发Lambda实现简单，但可能因并发限制导致执行失败。若需自动重试和并发控制，可改用Kinesis Data Streams作为事件源，通过事件源映射批量处理记录，从而减少调用次数并提高可靠性。读者应根据对错误处理和并发管理的需求选择方案。
数据一致性：SQL执行时的关键考量
由于无法使用事务，SQL发行方必须确保数据一致性。例如，当Lambda需要同时写入数据库A和B时，多记录更新会使应用逻辑复杂化。文章强调，在实现数据同步时，应优先考虑如何保证跨库操作的原子性，避免部分更新导致的数据不一致。
处理Kinesis数据：编码与压缩的注意事项
CloudWatch Logs中的数据是UTF-8编码且经过gzip压缩的。在Kinesis Data Stream查看器中会显示乱码，因此处理时需先Base64解码再gzip解压。文章提供了命令行示例，并指出Lambda测试模板中的kinesis-get-records数据未压缩，测试前需自行准备符合格式的数据。
C#实现参考：解析Kinesis事件与日志
文章提供了C#处理Kinesis事件的示例代码，包括解压数据、解析JSON日志事件，并使用正则表达式分割日志消息以提取特定字段。由于官方文档中C#示例较少，作者通过试错实现了该方案，可供需要在.NET环境中处理Kinesis数据的开发者参考。
Q&A
如何通过审计日志和CloudWatch触发AWS Lambda函数？
可以使用审计日志记录数据库的写入操作，并通过Amazon CloudWatch触发AWS Lambda函数，从而实现数据同步。
Kinesis Data Streams在Lambda函数中的作用是什么？
Kinesis Data Streams可以处理Lambda函数的错误，并控制并发执行数，确保在执行错误时能够自动重试。
在使用Lambda时，如何处理数据一致性问题？
在执行SQL时，需要确保数据一致性，特别是在多个数据库之间写入时，应用程序逻辑可能会变得复杂。
CloudWatch Logs中的数据格式是什么？
CloudWatch Logs中的数据是UTF-8编码且经过gzip压缩的，处理时需要注意解压缩和解码。
如何在C#中处理Kinesis DataStream数据？
可以使用C#编写Lambda函数，处理Kinesis事件并记录数据，示例代码中展示了如何解压缩和解析数据。
如何进行Base64解码和gzip解压缩？
可以使用命令行工具进行Base64解码和gzip解压缩，示例命令提供了具体的操作步骤。
