Tutorial: creazione di un'API REST come un proxy Amazon Kinesis

Per creare il ruolo di esecuzione del proxy dei servizi AWS

1. Accedi a Console di gestione AWS e apri la console IAM all'indirizzo https://console.aws.amazon.com/iam/.

2. Scegliere Roles (Ruoli).

3. Scegli Crea ruolo.

4. Scegli Servizio AWS in Seleziona il tipo di entità attendibile, quindi seleziona Gateway API e scegli Consente a Gateway API di inviare i log a File di log CloudWatch.

5. Scegli Successivo e di nuovo Successivo.

6. In Role name (Nome ruolo) immettere APIGatewayKinesisProxyPolicy e quindi selezionare Create role (Crea ruolo).

7. Nell'elenco Roles (Ruoli) scegliere il ruolo appena creato. Potrebbe essere necessario scorrere o utilizzare la barra di ricerca per trovare il ruolo.

8. Per il ruolo selezionato, seleziona la scheda Aggiungi autorizzazioni.

9. Dall'elenco a discesa scegli Collega policy.

10. Nella barra di ricerca inserisci AmazonKinesisFullAccess e scegli Aggiungi autorizzazioni.

    Nota

    Per semplicità, questo tutorial utilizza una policy gestita. Come best practice, dovresti creare la tua policy IAM per concedere le autorizzazioni minime richieste.

11. Annota l'ARN del ruolo appena creato, lo utilizzerai in seguito.

Per creare un'API come un proxy dei servizi AWS per Kinesis

1. Accedere alla console API Gateway all'indirizzo https://console.aws.amazon.com/apigateway.

2. Se si utilizza API Gateway per la prima volta, verrà visualizzata una pagina che presenta le caratteristiche del servizio. In API REST, scegliere Crea. Quando appare il popup Create Example API (Crea API di esempio), scegliere OK.

   Se non è la prima volta che si utilizza API Gateway, scegliere Create API (Crea API). In API REST, scegliere Crea.

3. Selezionare New API (Nuova API).

4. Per API name (Nome API) immettere KinesisProxy. Per tutti gli altri campi mantieni i valori predefiniti.

5. (Facoltativo) In Description (Descrizione), immettere una descrizione.

6. Per Tipo di indirizzo IP, selezionare IPv4.

7. Seleziona Create API (Crea API).

Per elencare i flussi Kinesis utilizzando la console API Gateway

1. Seleziona la risorsa /, quindi scegli Crea risorsa.

2. Per Resource Name (Nome risorsa) immetti streams.

3. Mantieni CORS (Cross Origin Resource Sharing) disattivato.

4. Scegli Crea risorsa.

5. Scegli la risorsa /streams e seleziona Crea metodo, quindi procedi come segue:

   1. Per Tipo di metodo seleziona GET.

      Nota

      Il verbo HTTP per un metodo richiamato da un client può differire dal verbo HTTP per un'integrazione richiesta dal back-end. Qui selezioniamo GET perché la visualizzazione dell'elenco di flussi è intuitivamente un'operazione READ.

   2. Per Tipo di integrazione seleziona Servizio AWS.

   3. Per Regione AWS seleziona la Regione AWS in cui hai creato il flusso Kinesis.

   4. Per Servizio AWS seleziona Kinesis.

   5. Lascia vuoto Sottodominio AWS.

   6. Per HTTP method (Metodo HTTP) scegli POST.

      Nota

      Qui scegliamo POST perché Kinesis richiede che con il metodo venga richiamata l'operazione ListStreams.

   7. Per Tipo di operazione scegli Usa nome operazione.

   8. Per Nome azione immetti ListStreams.

   9. Per Ruolo di esecuzione immetti l'ARN del ruolo di esecuzione.

   10. Lascia il valore predefinito Transito per Gestione contenuti.

   11. Scegli Crea metodo.

6. Nella scheda Richiesta di integrazione scegli Modifica in Impostazioni della richiesta di integrazione.

7. Per Richiesta corpo passthrough scegli Quando non ci sono modelli definiti (consigliato).

8. Scegli Parametri delle intestazioni delle richieste URL ed effettua le seguenti operazioni:

   1. Scegli Aggiungi parametro delle intestazioni delle richieste.

   2. Per Nome, immetti Content-Type.

   3. In Mappato da, inserire 'application/x-amz-json-1.1'.

   Usiamo la mappatura dei parametri delle richieste per impostare l'intestazione Content-Type sul valore statico 'application/x-amz-json-1.1' per indicare a Kinesis che l'input è una versione specifica di JSON.

9. Scegli Modelli di mappatura, quindi seleziona Aggiungi modello di mappatura ed effettua le seguenti operazioni:

   1. Per Content-Type immetti application/json.

   2. Per Corpo del modello immetti {}.

   3. Selezionare Salva.

   La richiesta ListStreams accetta un payload del formato JSON seguente:

   
   {
       "ExclusiveStartStreamName": "string",
       "Limit": number
   }
                       

   Tuttavia, le proprietà sono facoltative. Per usare i valori predefiniti, qui abbiamo optato per un payload JSON vuoto.

10. Testa il metodo GET nella risorsa /streams per richiamare l'azione ListStreams in Kinesis:

    Seleziona la scheda Test. Potrebbe essere necessario scegliere il pulsante freccia destra per visualizzare la scheda.

    Scegli Esegui test per testare il metodo.

    Se hai già creato due flussi denominati "myStream" e "yourStream" in Kinesis, il test con esito positivo restituisce una risposta 200 OK che contiene il payload seguente:

    
    {
         "HasMoreStreams": false,
         "StreamNames": [
             "myStream",
             "yourStream"
         ]
    }            
                        

Per creare la risorsa {stream-name}

1. Scegli la risorsa /streams, quindi seleziona Crea risorsa.

2. Mantieni l'opzione Risorsa proxy disattivata.

3. Per Percorso risorsa seleziona /streams.

4. Per Resource Name (Nome risorsa) immetti {stream-name}.

5. Mantieni CORS (Cross Origin Resource Sharing) disattivato.

6. Scegli Crea risorsa.

Per configurare e testare il metodo GET in una risorsa flusso

1. Scegli la risorsa /{stream-name}, quindi seleziona Crea metodo.

2. Per Tipo di metodo seleziona GET.

3. Per Tipo di integrazione seleziona Servizio AWS.

4. Per Regione AWS seleziona la Regione AWS in cui hai creato il flusso Kinesis.

5. Per Servizio AWS seleziona Kinesis.

6. Lascia vuoto Sottodominio AWS.

7. Per HTTP method (Metodo HTTP) scegli POST.

8. Per Tipo di operazione scegli Usa nome operazione.

9. Per Nome azione immetti DescribeStream.

10. Per Ruolo di esecuzione immetti l'ARN del ruolo di esecuzione.

11. Lascia il valore predefinito Transito per Gestione contenuti.

12. Scegli Crea metodo.

13. Nella sezione Richiesta di integrazione aggiungi i seguenti parametri delle intestazioni delle richieste URL:

    Content-Type: 'x-amz-json-1.1'

    L'attività segue la stessa procedura usata per configurare la mappatura dei parametri di richiesta per il metodo GET /streams.

14. Aggiungi il modello di mappatura del corpo seguente per mappare i dati dalla richiesta del metodo GET /streams/{stream-name} alla richiesta di integrazione POST /?Action=DescribeStream:

    {
        "StreamName": "$input.params('stream-name')"
    }

    Questo modello di mappatura genera il payload della richiesta di integrazione necessario per l'operazione DescribeStream di Kinesis dal valore del parametro di percorso stream-name della richiesta del metodo.

15. Per testare il metodo GET /stream/{stream-name} per richiamare l'azione DescribeStream in Kinesis, scegli la scheda Test.

16. Per Percorso immetti il nome di un flusso Kinesis esistente in stream-name.

17. Scegli Test (Esegui test). Se il test ha esito positivo, viene restituita una risposta 200 OK con un payload simile al seguente:

    {
      "StreamDescription": {
        "HasMoreShards": false,
        "RetentionPeriodHours": 24,
        "Shards": [
          {
            "HashKeyRange": {
              "EndingHashKey": "68056473384187692692674921486353642290",
              "StartingHashKey": "0"
            },
            "SequenceNumberRange": {
              "StartingSequenceNumber": "49559266461454070523309915164834022007924120923395850242"
            },
            "ShardId": "shardId-000000000000"
          },
          ...
          {
            "HashKeyRange": {
              "EndingHashKey": "340282366920938463463374607431768211455",
              "StartingHashKey": "272225893536750770770699685945414569164"
            },
            "SequenceNumberRange": {
              "StartingSequenceNumber": "49559266461543273504104037657400164881014714369419771970"
            },
            "ShardId": "shardId-000000000004"
          }
        ],
        "StreamARN": "arn:aws:kinesis:us-east-1:12345678901:stream/myStream",
        "StreamName": "myStream",
        "StreamStatus": "ACTIVE"
      }
    }

    Dopo aver distribuito l'API, puoi effettuare una richiesta REST su questo metodo API:

    
    GET https://your-api-id.execute-api.region.amazonaws.com/stage/streams/myStream HTTP/1.1
    Host: your-api-id.execute-api.region.amazonaws.com
    Content-Type: application/json
    Authorization: ...
    X-Amz-Date: 20160323T194451Z
    
                        

Per configurare e testare il metodo POST in una risorsa flusso

1. Scegli la risorsa /{stream-name}, quindi seleziona Crea metodo.

2. Per Tipo di metodo seleziona POST.

3. Per Tipo di integrazione seleziona Servizio AWS.

4. Per Regione AWS seleziona la Regione AWS in cui hai creato il flusso Kinesis.

5. Per Servizio AWS seleziona Kinesis.

6. Lascia vuoto Sottodominio AWS.

7. Per HTTP method (Metodo HTTP) scegli POST.

8. Per Tipo di operazione scegli Usa nome operazione.

9. Per Nome azione immetti CreateStream.

10. Per Ruolo di esecuzione immetti l'ARN del ruolo di esecuzione.

11. Lascia il valore predefinito Transito per Gestione contenuti.

12. Scegli Crea metodo.

13. Nella sezione Richiesta di integrazione aggiungi i seguenti parametri delle intestazioni delle richieste URL:

    Content-Type: 'x-amz-json-1.1'

    L'attività segue la stessa procedura usata per configurare la mappatura dei parametri di richiesta per il metodo GET /streams.

14. Aggiungi il modello di mappatura del corpo seguente per mappare i dati dalla richiesta del metodo POST /streams/{stream-name} alla richiesta di integrazione POST /?Action=CreateStream:

    {
        "ShardCount": #if($input.path('$.ShardCount') == '') 5 #else $input.path('$.ShardCount') #end,
        "StreamName": "$input.params('stream-name')"
    }

    Nel modello di mappatura precedente impostiamo ShardCount sul valore fisso 5 se il client non specifica alcun valore nel payload della richiesta del metodo.

15. Per testare il metodo POST /stream/{stream-name} per richiamare l'azione CreateStream in Kinesis, scegli la scheda Test.

16. Per Percorso immetti il nome di un nuovo flusso Kinesis in stream-name.

17. Scegli Test (Esegui test). Se il test ha esito positivo, viene restituita una risposta 200 OK senza dati.

    Dopo aver distribuito l'API, puoi anche effettuare una richiesta API REST sul metodo POST in una risorsa flusso per richiamare l'operazione CreateStream in Kinesis:

    
    POST https://your-api-id.execute-api.region.amazonaws.com/stage/streams/yourStream HTTP/1.1
    Host: your-api-id.execute-api.region.amazonaws.com
    Content-Type: application/json
    Authorization: ...
    X-Amz-Date: 20160323T194451Z
    
    { 
        "ShardCount": 5
    }
                        

Configurazione e test del metodo DELETE in una risorsa flusso

1. Scegli la risorsa /{stream-name}, quindi seleziona Crea metodo.

2. Per Tipo di metodo seleziona DELETE.

3. Per Tipo di integrazione seleziona Servizio AWS.

4. Per Regione AWS seleziona la Regione AWS in cui hai creato il flusso Kinesis.

5. Per Servizio AWS seleziona Kinesis.

6. Lascia vuoto Sottodominio AWS.

7. Per HTTP method (Metodo HTTP) scegli POST.

8. Per Tipo di operazione scegli Usa nome operazione.

9. Per Nome azione immetti DeleteStream.

10. Per Ruolo di esecuzione immetti l'ARN del ruolo di esecuzione.

11. Lascia il valore predefinito Transito per Gestione contenuti.

12. Scegli Crea metodo.

13. Nella sezione Richiesta di integrazione aggiungi i seguenti parametri delle intestazioni delle richieste URL:

    Content-Type: 'x-amz-json-1.1'

    L'attività segue la stessa procedura usata per configurare la mappatura dei parametri di richiesta per il metodo GET /streams.

14. Aggiungi il modello di mappatura del corpo seguente per mappare i dati dalla richiesta del metodo DELETE /streams/{stream-name} alla richiesta di integrazione corrispondente di POST /?Action=DeleteStream:

    {
        "StreamName": "$input.params('stream-name')"
    }

    Questo modello di mappatura genera l'input richiesto per l'operazione DELETE /streams/{stream-name} dal nome di percorso URL fornito dal client stream-name.

15. Per testare il metodo DELETE /stream/{stream-name} per richiamare l'azione DeleteStream in Kinesis, scegli la scheda Test.

16. Per Percorso immetti il nome di un flusso Kinesis esistente in stream-name.

17. Scegli Test (Esegui test). Se il test ha esito positivo, viene restituita una risposta 200 OK senza dati.

    Dopo aver distribuito l'API, puoi anche effettuare la richiesta API REST seguente sul metodo DELETE nella risorsa flusso per chiamare l'operazione DeleteStream in Kinesis:

    
    DELETE https://your-api-id.execute-api.region.amazonaws.com/stage/streams/yourStream HTTP/1.1
    Host: your-api-id.execute-api.region.amazonaws.com
    Content-Type: application/json
    Authorization: ...
    X-Amz-Date: 20160323T194451Z
    
    {}
                        

Per creare le risorse /record, /records e /sharditerator

1. Scegli la risorsa /{stream-name}, quindi seleziona Crea risorsa.

2. Mantieni l'opzione Risorsa proxy disattivata.

3. Per Percorso risorsa seleziona /{stream-name}.

4. Per Resource Name (Nome risorsa) immetti record.

5. Mantieni CORS (Cross Origin Resource Sharing) disattivato.

6. Scegli Crea risorsa.

7. Ripeti le fasi precedenti per creare una risorsa /records e una risorsa /sharditerator. L'API finale sarà simile alla seguente:

   

Per configurare e testare il metodo PUT /streams/{stream-name}/record per richiamare PutRecord in Kinesis:

1. Scegli la risorsa /record, quindi seleziona Crea metodo.

2. Per Tipo di metodo seleziona PUT.

3. Per Tipo di integrazione seleziona Servizio AWS.

4. Per Regione AWS seleziona la Regione AWS in cui hai creato il flusso Kinesis.

5. Per Servizio AWS seleziona Kinesis.

6. Lascia vuoto Sottodominio AWS.

7. Per HTTP method (Metodo HTTP) scegli POST.

8. Per Tipo di operazione scegli Usa nome operazione.

9. Per Nome azione immetti PutRecord.

10. Per Ruolo di esecuzione immetti l'ARN del ruolo di esecuzione.

11. Lascia il valore predefinito Transito per Gestione contenuti.

12. Scegli Crea metodo.

13. Nella sezione Richiesta di integrazione aggiungi i seguenti parametri delle intestazioni delle richieste URL:

    Content-Type: 'x-amz-json-1.1'

    L'attività segue la stessa procedura usata per configurare la mappatura dei parametri di richiesta per il metodo GET /streams.

14. Aggiungi il modello di mappatura del corpo seguente per mappare i dati dalla richiesta del metodo PUT /streams/{stream-name}/record alla richiesta di integrazione corrispondente di POST /?Action=PutRecord:

    {
        "StreamName": "$input.params('stream-name')",
        "Data": "$util.base64Encode($input.json('$.Data'))",
        "PartitionKey": "$input.path('$.PartitionKey')"
    }

    Questo modello di mappatura presuppone che il payload della richiesta del metodo abbia il formato seguente:

    {
       "Data": "some data",
       "PartitionKey": "some key"
    }

    Questi dati possono essere modellati tramite lo schema JSON seguente:

    {
      "$schema": "http://json-schema.org/draft-04/schema#",
      "title": "PutRecord proxy single-record payload",
      "type": "object",
      "properties": {
          "Data": { "type": "string" },
          "PartitionKey": { "type": "string" }
      }
    }

    Puoi creare un modello per includere questo schema e usare il modello per semplificare la generazione del modello di mappatura. Tuttavia, puoi generare un modello di mappatura senza usare alcun modello.

15. Per testare il metodo PUT /streams/{stream-name}/record, imposta la variabile di percorso stream-name sul nome di un flusso esistente, fornisci un payload con il formato richiesto e quindi invia la richiesta del metodo. Il risultato con esito positivo è una risposta 200 OK con un payload nel formato seguente:

    
    {
      "SequenceNumber": "49559409944537880850133345460169886593573102115167928386",
      "ShardId": "shardId-000000000004"
    }
                        

Per configurare e testare il metodo PUT /streams/{stream-name}/records per richiamare PutRecords in Kinesis

1. Scegli la risorsa /records, quindi seleziona Crea metodo.

2. Per Tipo di metodo seleziona PUT.

3. Per Tipo di integrazione seleziona Servizio AWS.

4. Per Regione AWS seleziona la Regione AWS in cui hai creato il flusso Kinesis.

5. Per Servizio AWS seleziona Kinesis.

6. Lascia vuoto Sottodominio AWS.

7. Per HTTP method (Metodo HTTP) scegli POST.

8. Per Tipo di operazione scegli Usa nome operazione.

9. Per Nome azione immetti PutRecords.

10. Per Ruolo di esecuzione immetti l'ARN del ruolo di esecuzione.

11. Lascia il valore predefinito Transito per Gestione contenuti.

12. Scegli Crea metodo.

13. Nella sezione Richiesta di integrazione aggiungi i seguenti parametri delle intestazioni delle richieste URL:

    Content-Type: 'x-amz-json-1.1'

    L'attività segue la stessa procedura usata per configurare la mappatura dei parametri di richiesta per il metodo GET /streams.

14. Aggiungi il modello di mappatura seguente per mappare i dati dalla richiesta del metodo PUT /streams/{stream-name}/records alla richiesta di integrazione corrispondente di POST /?Action=PutRecords:

    {
        "StreamName": "$input.params('stream-name')",
        "Records": [
           #foreach($elem in $input.path('$.records'))
              {
                "Data": "$util.base64Encode($elem.data)",
                "PartitionKey": "$elem.partition-key"
              }#if($foreach.hasNext),#end
            #end
        ]
    }

    Questo modello di mappatura presuppone che il payload della richiesta del metodo possa essere modellato tramite lo schema JSON seguente:

    {
      "$schema": "http://json-schema.org/draft-04/schema#",
      "title": "PutRecords proxy payload data",
      "type": "object",
      "properties": {
        "records": {
          "type": "array",
          "items": {
            "type": "object",
            "properties": {
              "data": { "type": "string" },
              "partition-key": { "type": "string" }
            }
          }
        }
      }
    }

    Puoi creare un modello per includere questo schema e usare il modello per semplificare la generazione del modello di mappatura. Tuttavia, puoi generare un modello di mappatura senza usare alcun modello.

    In questo tutorial abbiamo usato due formati di payload leggermente diversi per mostrare come uno sviluppatore di API possa scegliere di esporre il formato di dati di back-end al client o nasconderlo dal client. Un formato è per il metodo PUT /streams/{stream-name}/records (sopra). Un altro formato viene usato per il metodo PUT /streams/{stream-name}/record (nella procedura precedente). Nell'ambiente di produzione devi mantenere i due formati coerenti.

15. Per testare il metodo PUT /streams/{stream-name}/records, imposta la variabile di percorso stream-name su un flusso esistente, fornisci il payload seguente e invia la richiesta del metodo.

    
    {
        "records": [
            {
                "data": "some data",
                "partition-key": "some key"
            },
            {
                "data": "some other data",
                "partition-key": "some key"
            }
        ]
    }
                            

    Il risultato con esito positivo è una risposta 200 OK con un payload simile all'output seguente:

    {
      "FailedRecordCount": 0,
      "Records": [
        {
          "SequenceNumber": "49559409944537880850133345460167468741933742152373764162",
          "ShardId": "shardId-000000000004"
        },
        {
          "SequenceNumber": "49559409944537880850133345460168677667753356781548470338",
          "ShardId": "shardId-000000000004"
        }
      ]
    }

Per configurare e testare il metodo GET /streams/{stream-name}/sharditerator per richiamare GetShardIterator in Kinesis

Il metodo GET /streams/{stream-name}/sharditerator è un metodo helper per acquisire un'iterazione shard necessaria prima di chiamare il metodo GET /streams/{stream-name}/records.

1. Scegli la risorsa /sharditerator, quindi seleziona Crea metodo.

2. Per Tipo di metodo seleziona GET.

3. Per Tipo di integrazione seleziona Servizio AWS.

4. Per Regione AWS seleziona la Regione AWS in cui hai creato il flusso Kinesis.

5. Per Servizio AWS seleziona Kinesis.

6. Lascia vuoto Sottodominio AWS.

7. Per HTTP method (Metodo HTTP) scegli POST.

8. Per Tipo di operazione scegli Usa nome operazione.

9. Per Nome azione immetti GetShardIterator.

10. Per Ruolo di esecuzione immetti l'ARN del ruolo di esecuzione.

11. Lascia il valore predefinito Transito per Gestione contenuti.

12. Scegli Parametri della stringa di query URL.

    L'operazione GetShardIterator richiede l'immissione di un valore ShardId. Per passare un valore ShardId fornito dal client, aggiungiamo un parametro di query shard-id alla richiesta del metodo, come mostrato nella seguente fase.

13. Scegliere Add query string (Aggiungi stringa di query).

14. Per Nome, immetti shard-id.

15. Mantieni Obbligatorio e Caching disattivati.

16. Scegli Crea metodo.

17. Nella sezione Richiesta di integrazione aggiungi il seguente modello di mappatura per generare l'input richiesto (ShardId e StreamName) per l'azione GetShardIterator dei parametri shard-id e stream-name della richiesta del metodo. Inoltre, il modello di mappatura imposta anche ShardIteratorType su TRIM_HORIZON come comportamento predefinito.

    {
        "ShardId": "$input.params('shard-id')",
        "ShardIteratorType": "TRIM_HORIZON",
        "StreamName": "$input.params('stream-name')"
    }

18. Usando l'opzione Test nella console API Gateway, immetti il nome di un flusso esistente come valore della variabile stream-namePath (Percorso), imposta shard-idQuery string (Stringa di query) su un valore ShardId esistente, ad esempio shard-000000000004, e seleziona Test.

    Il payload di risposta di esito positivo è simile all'output seguente:

    {
      "ShardIterator": "AAAAAAAAAAFYVN3VlFy..."
    }

    Annota il valore di ShardIterator. Ti servirà per ottenere record da un flusso.

Per configurare e testare il metodo GET /streams/{stream-name}/records per richiamare l'operazione GetRecords in Kinesis

1. Scegli la risorsa /records, quindi seleziona Crea metodo.

2. Per Tipo di metodo seleziona GET.

3. Per Tipo di integrazione seleziona Servizio AWS.

4. Per Regione AWS seleziona la Regione AWS in cui hai creato il flusso Kinesis.

5. Per Servizio AWS seleziona Kinesis.

6. Lascia vuoto Sottodominio AWS.

7. Per HTTP method (Metodo HTTP) scegli POST.

8. Per Tipo di operazione scegli Usa nome operazione.

9. Per Nome azione immetti GetRecords.

10. Per Ruolo di esecuzione immetti l'ARN del ruolo di esecuzione.

11. Lascia il valore predefinito Transito per Gestione contenuti.

12. Scegli Intestazioni di richiesta HTTP.

    L'operazione GetRecords richiede l'immissione di un valore ShardIterator. Per passare un valore ShardIterator fornito dal client, si aggiunge un parametro di intestazione Shard-Iterator alla richiesta del metodo.

13. Seleziona Add header (Aggiungi intestazione).

14. Per Nome, immetti Shard-Iterator.

15. Mantieni Obbligatorio e Caching disattivati.

16. Scegli Crea metodo.

17. Nella sezione Richiesta di integrazione aggiungi il seguente modello di mappatura del corpo per mappare il valore del parametro di intestazione Shard-Iterator al valore della proprietà ShardIterator del payload JSON per l'azione GetRecords in Kinesis.

    {
        "ShardIterator": "$input.params('Shard-Iterator')"
    }

18. Usando l'opzione Test nella console Gateway API, immetti il nome di un flusso esistente come valore della variabile Percorso stream-name, imposta Intestazione Shard-Iterator sul valore ShardIterator ottenuto dall'esecuzione del test del metodo GET /streams/{stream-name}/sharditerator (precedente) e scegli Test.

    Il payload di risposta di esito positivo è simile all'output seguente:

    {
      "MillisBehindLatest": 0,
      "NextShardIterator": "AAAAAAAAAAF...",
      "Records": [ ... ]
    }