如何找到firehose的直放地址？

Question

我创建了一个带有源输入的 aws

firehose

流：直接放入。

我现在在哪里可以看到地址，我可以将数据发送到。我找不到它。

Answer 1

您不需要地址或端点。您需要确保您拥有适当的权限才能将记录放入消防水带中。您只需要知道消防水带的名称及其所在区域，就可以开始了。

这是示例代码：

import datetime
import json
import random
import boto3

STREAM_NAME = "<STREAM_NAME>"
REGION_NAME = "<REGION>"

def get_data():
    """Generate random data."""
    return {
        'EVENT_TIME': datetime.datetime.now().isoformat(),
        'CITY': random.choice(['NYC', 'ITL', 'ABD', 'SRT', 'THI','HYD']),
        'TICKER': random.choice(['AAPL', 'AMZN', 'MSFT', 'INTC', 'TBV']),
        'PRICE': round(random.random() * 100, 2)
    }

def generate(stream_name, firehose_client):
    """Generate and send data to Kinesis Data Firehose."""
    while True:
        data = get_data()
        try:
            firehose_client.put_record(
                DeliveryStreamName=stream_name,
                Record={
                    'Data': json.dumps(data)
                }
            )
            print("Data sent successfully:", data)
        except Exception as e:
            print("Error:", e)

if __name__ == '__main__':
    firehose_client = boto3.client('firehose', region_name=REGION_NAME)
    generate(STREAM_NAME, firehose_client)