擅长:python、mysql、java
<p>更新的代码工人:在</p>
<pre><code>import time
import boto3
import stomp
import json
lambda_client = boto3.client('lambda')
kinesis_client = boto3.client('kinesis')
def lambda_handler(event, context):
print('received a message in worker : "%s"' % event)
kinesis_client.put_record(
StreamName='OnePurchasing',
Data=b'bytes',
PartitionKey='1'
)
</code></pre>