Подписка на AWS Amplify AppSync работает неправильно - PullRequest
Новая
       89

Подписка на AWS Amplify AppSync работает неправильно

0 голосов
/ 08 ноября 2019

Я написал небольшое приложение, которое подписывается на изменения БД с помощью AWS Amplify CLI / AppSync. Все вызовы API api работают отлично (мутации, запросы), но, к сожалению, наблюдатель не получает события. Я вижу, что сокет MQTT периодически получает двоичные файлы, но я не могу получить измененные объекты.

Я настроил Amplify для использования с усилением. Я вижу в отладчике, что AppSyncProvider был инициализирован. Также пробовал API и PubSub, но без разницы. 

        const awsmobile = {
            "aws_appsync_graphqlEndpoint": "https://[...].appsync-api.[...]/graphql",
            "aws_appsync_region": "[...]",
            "aws_appsync_authenticationType": "AMAZON_COGNITO_USER_POOLS",
        };

        Amplify.configure(awsmobile);

        ngOnInit() 
            {
                try {

                  this.apiService.OnUpdateA.subscribe(
                    {
                        next: (x) => {[...]},
                        error: (e) => {[...]},
                        complete: () => {[...]}
                    });
                } 
                catch (error) {[...]    }
            }

        ***Schema***
        type A
        @model 
        @auth(rules: [
              {allow: owner},
              {allow: groups, groups: ["A"], operations: [create, update, read]},
              {allow: groups, groups: ["B"], operations: [read]},
          ]) 
        {
          id: ID!
          entry: AnotherType! @connection(name: "AnotherConnection")
    [...]
        }

 OnUpdateAListener: Observable<
    OnUpdateASubscription
  > = API.graphql(
    graphqlOperation(
      `subscription OnUpdateA($owner: String) {
        onUpdateA(owner: $owner) {
          __typename
          id
          owner
       [...]
        }
      }`
    )
  ) as Observable<OnUpdateASubscription>;

Кто-нибудь для каких-либо идей? 

**Logs:**
{mqttConnections: Array(1), newSubscriptions: {…}, provider: Symbol(INTERNAL_AWS_APPSYNC_PUBSUB_PROVIDER)}
mqttConnections: Array(1)
0: {url: "wss://[...]-ats.iot.[...].amazonaws…[...]%3D%3D", topics: Array(2), client: "[...]"}
length: 1
__proto__: Array(0)
newSubscriptions:
onUpdate:
expireTime: 1573313050000
topic: "[....]/22tmaezjv5555h4o7yreu24f7u/onUpdate/1cd033bad555ba55555a20690d3e04e901145776d3b8d8ac95a0aea447b273c3"
__proto__: Object
__proto__: Object
provider: Symbol(INTERNAL_AWS_APPSYNC_PUBSUB_PROVIDER)
__proto__: Object

Однако не уверены, подозрительно ли, что у объекта подписки нет очереди? 

Subscription {_observer: {…}, _queue: undefined, _state: "ready", _cleanup: ƒ}
_cleanup: ƒ ()
_observer:
next: (x) => {…}
__proto__: Object
_queue: ***undefined***
_state: "ready"
closed: (...)
__proto__: Object

Заранее большое спасибо.

Ответы [ 2 ]

0 голосов
/ 11 ноября 2019

Я думаю, что ваш пример использует альтернативу TypeScript. Я пытаюсь использовать Angular альтернативу ampolify cli, которая генерирует API.service.ts.

Итак, моя подписка выглядит примерно так 

OnUpdateAListener: Observable<
    OnUpdateASubscription
  > = API.graphql(
    graphqlOperation(
      `subscription OnUpdateA($owner: String) {
        onUpdateA(owner: $owner) {
          __typename
          id
          oid
          name
          address
         [...]
          owner
        }
      }`
    )
  ) as Observable<OnUpdateASubscription>;

Вы случайно не знаете, нужно ли заполнять все поля в подписке так, чтобы событие инициировалось или было бы достаточно, чтобытолько некоторые поля обновляются?

Верно ли мое предположение, что значение владельца установлено автоматически?

0 голосов
/ 08 ноября 2019

Вот рабочий пример расширенной подписки AWS: 


import Amplify from 'aws-amplify';
import API from '@aws-amplify/api';
import PubSub from '@aws-amplify/pubsub';
import awsconfig from './aws-exports';

Amplify.configure(awsconfig);
API.configure(awsconfig);
PubSub.configure(awsconfig);

// put above in root

// below is example 

import { API, graphqlOperation } from 'aws-amplify';

var  onAddNote = `subscription OnCreateNote {
    onCreateNote {
        id
        patient {
            id
            organization {
                id
            }
        }   
    }
}
`;

listenForNoteAdd() {
        return API.graphql(graphqlOperation(onAddNote) ).subscribe({next: (noteData) => {
            console.log("new note so reload consider reload")
            let note = noteData.value.data.onCreateNote
            console.log(JSON.stringify(note))

            // now that you have indication of something happening 
            // do what you must next

        }})    
    }
...