Почему моя функция подписки не работает? - PullRequest
Новая
       39

Почему моя функция подписки не работает?

1 голос
/ 08 апреля 2019

Я последовал примеру на веб-сайте AWS до тройника https://aws -amplify.github.io / docs / js / pubsub

, и что бы я ни делал, каждый разЗапустите await PubSub.publish Я не получил ответа от AWS.Любая помощь будет оценена.Я получаю тайм-ауты для кода.

Triend различные способы взаимодействия с AWS через MQTT реагировать на родной.Искал везде.Нет примеров этого использования.

import Amplify, { PubSub, Auth } from 'aws-amplify';

import { AWSIoTProvider } from '@aws-amplify/pubsub/lib/Providers';

import aws_exports from './src/aws-exports';

// aythentication import
import { withAuthenticator } from 'aws-amplify-react-native';
Amplify.configure(aws_exports);


Amplify.addPluggable(new AWSIoTProvider({
     aws_pubsub_region: 'us-east-1',
     aws_pubsub_endpoint:  'wss://azk3aah4ivg82-ats.iot.us-east-1.amazonaws.com/mqtt',
}));

PubSub.subscribe(['$aws/things/B_Bone_1/shadow/get/accepted', '$aws/things/B_Bone_1/shadow/get/rejected']).subscribe({
    next: data => console.log('Message received get accepted', data),
    error: error => console.error(error),
    close: () => console.log('Done'),
});


//
export default class Main extends React.Component {
//...... sign in stuff This just makes a cognito accound and lets me log in. Its working
}


class App extends Component {
//constuct props 
///...
update = async () => {

    await PubSub.publish('$aws/things/B_Bone_1/shadow/update', {msg: '{"state":{"reported":{"temp": -1}}}' });

    Alert.alert('Update all local values from Device Shadow');
  }


render() {
    return (
    //A page with a button that runs update function
    );
    }}
    
//Stylesheet stuff

При вызове обновления программа должна запустить функцию подписки.Но я получаю ошибку тайм-аута, так как ничего не возвращается.Любая помощь будет потрясающей.

...