Deseo crear una Puerta de Enlace de la API que esté conectada a un flujo de Kinesis: resource “aws_api_gateway_integration” “kinesis_integration” { rest_api_id = aws_api_gateway_rest_api.kinesis.id resource_id = aws_api_gateway_resource.api_resource_kinesis.id http_method = aws_api_gateway_method.post_kinesis.http_method type = “AWS_PROXY” uri = “arn:aws:apigateway:eu-central-1:kinesis:action/PutRecord” integration_http_method = “POST” depends_on = [ aws_api_gateway_resource.resource_kinesis ] } resource “aws_kinesis_firehose_delivery_stream” “kinesis-stream” { name . . . Read more
Tengo el siguiente archivo JSON: { "@timestamp": "2021-11-19T21:32:55.196Z", "@version": "1", "mensaje": "Prueba manual para firehose." } Y tengo la siguiente función en Go: func insertIntoFireHose(sess *session.Session, hoseName string) { svc := firehose.New(sess, aws.NewConfig().WithRegion("us-east-1")) //firehoseData := getObjectFromS3Bucket(sess) firehoseData, _ := os.ReadFile("/temp/test.json") var rec firehose.Record var recInput firehose.PutRecordInput dataJson, _ := json.Marshal(firehoseData) . . . Read more
Usando este comando, puedo colocar datos en mi flujo de firehose. Automáticamente crea un archivo en el cubo de destino y coloca el valor de los datos en ese archivo. El archivo tiene un tipo de datos desconocido. aws firehose put-record –delivery-stream-name mystream –record="{\"Data\":\"1\"}" ¿En lugar de esto, es posible . . . Read more