如何在由lambda调用的Appsync中添加订阅？
在由Lambda调用的AppSync中添加订阅的步骤如下：
- 首先，确保你已经创建了一个AppSync API，并且已经配置了Lambda函数作为数据源。
- 打开AppSync控制台，选择你的API，并进入“Schema”选项卡。
- 在Schema选项卡中，你需要定义一个新的subscription类型。这个类型将定义你的订阅操作。例如，你可以定义一个名为"NewPostSubscription"的subscription类型，用于订阅新发布的帖子。
- 在subscription类型中，你需要定义一个字段，用于指定订阅的触发条件。例如，你可以定义一个名为"onNewPost"的字段，它的类型是一个自定义的对象类型，用于表示新发布的帖子。
- 在Lambda函数中，你需要添加逻辑来处理订阅请求。你可以使用AWS SDK或其他适当的工具来订阅和处理事件。当有新的帖子发布时，Lambda函数将触发并执行相应的逻辑。
- 在AppSync控制台的“Resolvers”选项卡中，你需要为subscription类型的字段添加一个解析器。这个解析器将指定如何调用Lambda函数来处理订阅请求。
- 配置解析器时，你需要指定Lambda函数的ARN（Amazon Resource Name）以及其他必要的参数。这将告诉AppSync如何调用Lambda函数来处理订阅请求。
- 保存并部署你的AppSync API的更改。
现在，当有新的帖子发布时，AppSync将触发订阅并调用Lambda函数来处理订阅请求。你可以在Lambda函数中执行任何逻辑，例如发送通知、更新UI等。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云函数（Serverless）：https://cloud.tencent.com/product/scf
- 腾讯云API网关：https://cloud.tencent.com/product/apigateway
- 腾讯云消息队列CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云云数据库MySQL版：https://cloud.tencent.com/product/cdb_mysql
- 腾讯云云服务器CVM：https://cloud.tencent.com/product/cvm
- 腾讯云云原生容器服务TKE：https://cloud.tencent.com/product/tke
- 腾讯云云存储COS：https://cloud.tencent.com/product/cos
- 腾讯云区块链服务：https://cloud.tencent.com/product/tbaas
- 腾讯云物联网平台：https://cloud.tencent.com/product/iotexplorer
- 腾讯云移动开发平台：https://cloud.tencent.com/product/mpe
- 腾讯云云函数Graph：https://cloud.tencent.com/product/graph
相关·内容
我正在对发布/订阅消息使用Appsync订阅。我读过一些关于订阅的文章(比如：)，它们都提到了specifying a GraphQL schema directive on a mutation。在我的例子中，我有一个由dynamodb streams触发的lambda，这个lambda需要将事件发布给订阅者。如何在Appsync<e
浏览 1提问于2020-06-02得票数 0
我有一个连接到步骤函数的DynamoDB，并且我正在构建一个UI来显示更改。我将数据库连接到一个AppSync实例，并尝试通过AppSync使用订阅，但他们似乎只观察到当前AppSync中的突变。如何直接订阅数据源变更？
浏览 2提问于2018-08-03得票数 12
回答已采纳
1回答
AWS AppSync授权
、、、、
我计划使用Appsync迁移lambda函数中的graphQL端点，该函数由POST通过API触发。我研究AppSync主要是因为订阅，我无法使用Lambda函数创建订阅。我的身份验证机制基于Auth0，使用无密码，我的授权机制基于来自DynamoDB中几个表的数据，它嵌入在graphQL解析器中，这是由Facebook和阿波罗
浏览 1提问于2018-01-24得票数 8
回答已采纳
我知道Appsync中的订阅与突变一起工作，这意味着每当调用突变时，订阅也会被调用，从而将消息发送给所有订阅者。我想要的是，如果有任何方法，我基本上可以使用Appsync或任何其他实时方式从lambda直接向用户发送消息？也就是说，我不希望用户刷新页面。用例可以是，比方说，我有一个独立的lambda，它每小时运行一次，并希望每小时通知用户一些事情。它不是任何变异或
浏览 5提问于2020-03-01得票数 1
我想启用CORS到其中一个路径，它作为指向后端appsync的http_proxy工作。appsync解析器指向dynamodb表。因此前端调用API网关，后者将请求传递给appsync，请求由dynamodb解析。
我的问题是在该特定路径上启用CORS。但是基于这个文档：，它说我必须在后端响应CORS头，这是一个lambda。但是我的后端没有lambda。所有的后端都是appsync +一些解析器
浏览 4提问于2021-05-17得票数 1
回答已采纳
我试图从lambda (特别是使用golang)中调用一个突变。我使用AWS_IAM作为AppSync API的身份验证方法。我还允许appsync:GraphQL允许我的lambda。但是，在查看了这里的文档之后：我不想查询、订阅或者其他来自<
浏览 2提问于2018-10-08得票数 1
回答已采纳
1回答
AppSync和推送通知
、、、
我想让我的AWS AppSync应用程序为移动应用程序(Android和iOS)推送通知做好准备，在移动应用程序中，我有一个GraphQL模式，Lambda作为数据源。问题是，我不知道什么是最好的解决办法。
或者您有什么建议，让我的<
浏览 0提问于2019-02-25得票数 3
我从Amplify Cli为我的angular项目创建了AppSync API。 该网站可以订阅OnChangeListner，其中DynamoDB通过突变进行更新。它起作用了。selectedItem.status await this.api.UpdateTable(update);
} 然而，我注意到，如果我手动更新DynamoDB，订阅根本不起作用任何关于如何更新DynamoDB (不是通过突变)和AppSync订阅的建议仍然有效。
浏览 30提问于2019-06-20得票数 3
目前，AWS AppSync只能订阅突变，这是获得实时更新的唯一方法。但是，如果对AppSync之外的备份数据进行了更改(比如Lambda函数的DynamoDB更新)，那么我们如何通知客户端呢？我看到的唯一解决方案是使用“本地”解析器创建一个突变，并让更新DynamoDB的Lambda调用此突变。但是，我的问题是AppSync身份验证，在我的例子
浏览 0提问于2018-05-11得票数 4
回答已采纳
正如标题所述，我希望从代码中触发订阅事件。
想一想用例，用户想在互联网上搜索最便宜的航班。Lambda功能开始抓取流行的机票，提供网站，并与每个发现发送一个订阅事件到一个应用程序。这种情况可以由AppSync托管吗？
浏览 0提问于2018-07-20得票数 5
回答已采纳
我有一个lambda函数，当dynamodb表中发生更改时会触发该函数。当我使用lambda解析器时，我只能从appsync中调用lambda函数，这并不是我想要做的事情。我正在尝试遵循这里提供的答案：
}); req.write(data);});}；
我也在使用无服务器框架，这
浏览 0提问于2019-03-06得票数 1
我需要在Dynamodb表中执行一些crud操作，该表由Appsync API使用和创建。我需要从我通过amplify add function命令添加的lambda函数访问它。使用带有API id和环境的完整表名，如"User-apiid-dev“。但是，我不想在lambda函数中使用环境名称和API id来硬编码整个表名。
浏览 15提问于2020-03-15得票数 1
我有包含时间序列示例数据的JSON文件被输入到S3中。我有一个使用组件的React客户端，它需要显示最近x分钟样本数据的最新统计平均值。理想情况下，更新将由S3上传触发，而不是需要轮询the服务的浏览器。Websockets和服务器发送的事件不是选项。考虑到这些需求，我可以实际使用AWS Appsync的订阅来提供实时数据吗？我假设这将有利于在一个时间范围内查询数据以计算平均值，并且我假设我将使用S3触发Lambda
浏览 1提问于2018-04-10得票数 1
我正在尝试创建lambda函数来运行我的AppSync GraphQL API突变查询。我在网上看到了很多答案，但他们都试图先在本地机器上创建lambda，然后将其推到AWS云上。我不能遵循这个方法。基本上，我在appsync graphql后面有一个dynamodb数据库表。我想使用lambda函数更新dynamoDB中的条目。要更新这个条目(在DynamoDB中)，我需要在appsync graphql上运行一个
浏览 2提问于2021-07-01得票数 0
如我所知，订阅参数必须作为一个字段存在于突变的返回类型中。这意味着参数的类型还必须与突变的返回对象中的字段类型匹配。我说的对吗？假设我在突变响应中得到一个带有通道I的数组。我只发送一个通道id作为订阅中的参数。是否有可能在突变输出时将订阅参数映射到数组？如果通道id存在于数组(字段channelsIds)中，则订阅</e
浏览 2提问于2020-10-18得票数 2
回答已采纳
1回答
我目前正在构建一个使用AWS放大框架的。为了实现这一功能，我使用GraphQL订阅和AppSync API。由于某些原因，订阅不会响应DB上发生的事件。- subscription message from AWS AppSync RealTime: {"type":"ka"}
AWSAppSyncRealTim
浏览 5提问于2020-10-15得票数 1
回答已采纳
我目前正在使用AppSync实现AWS中的订阅突变。我想使用IAM，避免使用任何其他类型的AUTH机制，因为我在AWS堆栈中调用它。token included in the request is invalid."我试着跟着这些都没用，但我不知道我错过了什么：
{
"Statement&q
浏览 2提问于2021-04-24得票数 5
虽然AppSync是市场上的GraphQL，而API是用于REST的。但是也可以通过lambda的阿波罗服务器与GraphQL一起工作。
那么，究竟是什么让其中一个比另一个更好呢？
浏览 3提问于2021-01-20得票数 1
回答已采纳
1回答
过滤AppSync订阅
、、、、
我正在使用AppSync构建一个简单的多人游戏(以避免从零管理WebSocket )和放大器(特别是在安卓系统上，使用Kotlin)。问题是，当玩家连接到一个游戏时，应该倾听其他玩家的更新(考虑我有一个带有主键UUID和相应的玩家的游戏id和位置的发电机表)。所以我所做的是，在玩家加入他的游戏后，将自己注册到onUpdate of Player.但是现在他收到了所有玩家更新的通知.即使我可以轻松地过滤这个传入事件客户端，我认为这是一个
浏览 0提问于2021-03-05得票数 0
回答已采纳
我已经为我的GraphQL查询和突变实现了AWS授权层，这样一个用户只可以将数据读/写到特定的DynamoDB表项，如果他们是该项所属组的成员，则使用groupId分区键和itemId的某种键实现。这样，表就可以有多个具有公共groupId的groupId，也可以有许多不同的groupIds。这一切都如预期的那样起作用。
现在，我希望能够将这个组授权扩展到我的实时GraphQL订阅。我注意到，非参数化<em
浏览 0提问于2018-05-09得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
