iotdataplane - Resource not found

[eicca]

I'm trying following example, basically almost identical to one from examples_test.go:

var (
    svcSession = session.New(&aws.Config{
        Region: aws.String("eu-west-1"),
    })
    svc = iotdataplane.New(svcSession, &aws.Config{
        Endpoint: aws.String("data.iot.eu-west-1.amazonaws.com"),
    })
)

func main() {
    params := &iotdataplane.GetThingShadowInput{
        ThingName: aws.String("rPi"),
    }

    resp, err := svc.GetThingShadow(params)
    if err != nil {
        fmt.Println(err)
        return
    }
    fmt.Println(resp.Payload)
}

This code returns:

ResourceNotFoundException: Not Found
    status code: 404, request id: 88db4e32-9a92-43f8-aea5-4093a24639e2

(NOTE: I tried to use both data and our custom iot subdomains)

I can successfully fetch this device both with aws-cli and nodejs sdk:

var AWS = require('aws-sdk');
var endpoint = "data.iot.eu-west-1.amazonaws.com"

var iotdata = new AWS.IotData({
    endpoint: endpoint,
    region: "eu-west-1"
});

var params = {
    thingName: 'rPi'
};

iotdata.getThingShadow(params, function (err, data) {
    if (err) console.log(err, err.stack); // an error occurred
    else     console.log(data);           // successful response
});

This example successfully returns data about the shadow.

I checked request logs and they look almost identical. These are logs for go sdk: https://gist.github.com/eicca/d7cb7fb592bf329eacbb

iot package works fine and I can get attributes of this shadow with iot package.

Could you give a hint, what might be wrong here? Thanks.

[jasdel]

Thanks for reporting this issue @eicca. I was able to reproduce the issue you're seeing. I'm taking a look into what is going on here and update this issue when I have a workaround or solution.

[jasdel]

@eicca I've been working with the service team. We're investigating and working on a fix for this issue and will post and update when we have a fix together and available.

[brianfaull]

The iotdataplane.GetThingShadow() seems to be working now, but I only did a quick test. Is this issue closed, or are there remaining functional issues or testing to be completed? It bugs me (just a little bit :) every time I see my MQTT-based workaround scroll by in logs... but I don't want to be too hasty if it's not ready for primetime! Thank you.

[jasdel]

Hi @brianfaull thanks for contacting us. I've verified IoT data is now working as expected. The issue causing the SDK to be unable to communicate correctly with the IoT data service has been corrected. The following script exercies this.

package main

import (
    "fmt"
    "os"

    "github.com/aws/aws-sdk-go/aws"
    "github.com/aws/aws-sdk-go/aws/session"
    "github.com/aws/aws-sdk-go/service/iot"
    "github.com/aws/aws-sdk-go/service/iotdataplane"
)

// Usage: AWS_REGION=<region> AWS_PROFILE=<profile> go run iotdata.go <thingname> <topic>
func main() {
    if len(os.Args) != 3 {
        fmt.Println("Usage: AWS_REGION=<region> AWS_PROFILE=<profile> go run iotdata.go <thingname> <topic>")
        return
    }

    sess := session.New(aws.NewConfig().
        WithLogLevel(aws.LogDebugWithHTTPBody))

    iotSvc := iot.New(sess)
    res, err := iotSvc.DescribeEndpoint(&iot.DescribeEndpointInput{})
    if err != nil {
        fmt.Println("describe endpoint err", err)
        return
    }
    fmt.Println("Endpoint:", res)

    svc := iotdataplane.New(sess, &aws.Config{Endpoint: res.EndpointAddress})
    result, err := svc.Publish(&iotdataplane.PublishInput{
        Payload: []byte("my payload"),
        Topic:   &os.Args[2],
    })
    fmt.Println("publish", result, err)

    shadow, err := svc.GetThingShadow(&iotdataplane.GetThingShadowInput{
        ThingName: &os.Args[1],
    })
    fmt.Println("shadow", shadow, err)
}