我有一个quarkus REST api,它接受JSON字符串(各种类型)作为事件,然后将它们传播到KAFKA主题。

我现在想将可能的JSON字符串的结构放在openAPI合约中(无需自己手动键入)。

我已经找到了@requestbody标记,它允许我指定一个结构,但我有多种类型的事件,它们都必须指向同一个Kafka主题。

例子:

  @POST
  @Path("/student")
  @Consumes(MediaType.APPLICATION_JSON)
  @Produces(MediaType.APPLICATION_JSON)
  @Tag(name = "Student Events Service")
  @Operation(summary = "Accepts student type events", description = "Accepts student type events")
  @APIResponse(responseCode = "200", description = "Event sent successfully")
  @APIResponse(responseCode = "400", description = "The JSON packet sent did not conform to any known message or the primary key or shared data in the packet is invalid. \n "
               + "See Response Body for detail. -  "
               + "Error code 400-1 = Bad message structure or unknown message. Log error and continue to next message - "
               + "Error code 400-2 = Bad primary key. Fix data (client or server side) and retry later - "
               + "Error code 400-3 = Invalid shared data. Fix shared data and retry later",
               content = @Content(mediaType = "application/json",
                                  schema = @Schema(implementation = ErrorResponse.class)))
  @APIResponse(responseCode = "500", description = "Unexpected server error. See Response Body for detail. - "
               + "Error code 500-1 = Unable to send to KAFKA, please wait and retry later - "
               + "Error code 500-2 = Unable to connect to verification database, please wait and retry later - "
               + "Error code 500-3 = General server error, Please wait and retry later",
               content = @Content(mediaType = "application/json",
                                  schema = @Schema(implementation = ErrorResponse.class)))
  public Response postStudentEvent(String eventJSON) {

现在,我可以放入以下标记来生成一类事件JSON字符串的openapi合约

  @RequestBody(
        required = true,
        content = @Content(
          schema = @Schema(implementation = Application.class)
        )
  )

但是,假设我也希望能够接受具有CourseEnrollment.class结构的JSON字符串(这些类都是项目btw的一部分)。

public class CourseEnrollment {

  private String eventID;
  private String eventTime;
  private String eventType;
  private String eventUserSource;
  private String externalReference1;
  private String firstName;
  private String lastName;
  private String emailAddressPrimary;
  private String emailAddressAlternate;
  private String periodStartDate;
  private String periodEndDate;
  private String intakeIntakeYearCode;
  private String programmeCode;

 public class Application   {
  private String eventID;
  private String eventTime;
  private String eventType;
  private String eventUserSource;
  private String eventTrigger;

  
  private ApplicationInfo applicationDetails = null;

  private Person personDetails = null;

  private School schoolDetails = null;

我知道这是一个糟糕的场景,但这是我必须处理的,因为我们有一个外部系统生成事件并将JSON发送到我的REST服务,我必须将JSON传播到本地的KAFKA主题。

感谢您的投入

指定多个“;实现=“0”;quarkus REST api中@requestbody openapi标记中的标记的更多相关文章

  1. 保护MY REST API仅用于MY IOS APP

    我在Laravel中设计一个RESTAPI,用于我的ios应用程序.目前我被困在以下几点:如何保护我的RESTAPI只允许访问我的ios应用程序?听起来我需要通过向我的IOSAPP授予一个私钥来将类似于HMAC方法的内容合并到我的IOSAPP代码中.当从iosapp中运行请求时,我传递带有私钥和其他数据的哈希,然后当在服务器上收到请求时,我通过重新计算哈希来检测请求是否来自应用程序内的用户.我不知道这是否安全&我会认为不是吗?

  2. REST API iOS开发

    我将RestKitAPI设置到我的应用程序有很多麻烦.我想知道有没有其他好的API来制作RESTful应用程序?

  3. 泛型 – Swift相当于MIN和MAX宏

    在C/Objective-C中,可以使用MIN和MAX宏找到两个数字之间的最小值和最大值。Swift不支持宏,似乎在语言/基础库中没有等价物。应该有一个定制的解决方案,也许基于类似这样的one?min和max已经在Swift中定义:看到这个伟大的写在documented&undocumentedbuilt-infunctionsinSwift。

  4. 在Swift中调用REST API

    我试图使用Swift对RESTAPI进行GET调用,并试图遵循许多教程,但不能弄清楚。或者是因为我不知道如何将所有的Obj-C翻译成Swift,或者因为一半的方法n’都被弃用。有谁知道如何进行调用,并解析返回的JSON数据?

  5. android – 如何仅限授权客户端访问我的REST API?

    题我设计的RESTAPI将用于iOS和Android应用程序,以及将来可能用于Web和其他移动客户端.如何将我的整个API仅限制为我想要访问的客户端?我想阻止第三方访问我的API以注册用户,甚至无需通过授权应用程序登录.目前的想法我可以为每个客户端提供我想要授权的密钥,但是如何防止从我的应用程序的源代码中提取此密钥?

  6. 在Android上同步SQL数据库与REST远程服务器的最佳实践

    编辑:例如,采用方法2,重写的ContentProvider#bulkInsert使用数据库事务可以大大加快批量插入操作:见thisquestion.解决方法最佳选择需要适当的API实现–何时应存储一些db_version.并且在更新服务器期间响应数据和操作类型–添加,更新,删除.

  7. 如何在Android上托管REST webservices?

    有没有人知道一个用Java编写的能够在Android上托管REST服务的开源Web服务器?

  8. android – Twitter OAuth Rest Api状态参数’@’符号

    我正在使用twitterrestapi,这是(https://api.twitter.com/1.1/).首先,我使用路标库生成oauth_signature.它运作良好.上传状态端点(https://api.twitter.com/1.1/statuses/upload.json)运行良好,但如果状态参数包含“@”符号,则表示无效.所以这是我的代码TwitterStatusesService.j

  9. android rest客户端不支持的媒体类型

    我尝试从android模拟器发送请求到一个安静的服务器.但我总是得到错误:415UnsupportedMediaType.客户代码:服务器的代码:解决方法问题是服务器不知道客户端请求的媒体类型.在客户端代码中尝试这样的事情:request.setHeader(“Content-Type”,“application/json”);

  10. android – 解析REST API不返回客户端密钥

    我正在尝试动态创建Parse应用程序并在构建我的Android应用程序时使用这些键.TheAPI工作得很好,除了一点,它不会返回客户端密钥.我需要AndroidAPI中提到的客户端密钥:我试图徒劳地翻转旗帜.我应该怎么做才能访问客户端密钥?

随机推荐

  1. 如何扩展ATmega324PB微控制器的以下宏寄存器?

    我目前正在学习嵌入式,我有以下练习:展开以下宏寄存器:如果有人解决了这个问题,我将不胜感激,以便将来参考

  2. Python将ONNX运行时设置为返回张量而不是numpy数组

    在python中,我正在加载预定义的模型:然后我加载一些数据并运行它:到目前为止,它仍在正常工作,但我希望它默认返回Tensor列表,而不是numpy数组。我对ONNX和PyTorch都是新手,我觉得这是我在这里缺少的基本内容。这将使转换中的一些开销相同。

  3. 在macOS上的终端中使用Shell查找文件中的单词

    我有一个文本文件,其中有一行:我需要找到ID并将其提取到变量中。我想出了一个RexEx模式:但它似乎对我尝试过的任何东西都不起作用:grep、sed——不管怎样。我的一个尝试是:我为这样一个看似愚蠢的问题感到抱歉,但我在互联网上找不到任何东西:我在SO和SE上读了几十个类似的问题,并在谷歌上搜索了几个教程,但仍然无法找到答案。欢迎提供任何指导!

  4. react-chartjs-2甜甜圈图中只有标题未更新

    我正在使用react-chartjs-2在我的网站中实现甜甜圈图。下面是我用来呈现图表的代码。我将甜甜圈图的详细信息从父组件传递到子组件,所有道具都正确传递。当我在beforeDraw函数外部记录props.title时,它会记录正确的值,但当我在beforeDraw函数内部记录props.title时,它将记录标题的前一个值,从而呈现标题的前值。我在这里做错了什么?

  5. 如何在tkinter中使用Python生成器函数?

    生成器函数承诺使某些代码更易于编写。但我并不总是知道如何使用它们。假设我有一个斐波那契生成器函数fib(),我想要一个显示第一个结果的tkinter应用程序。当我点击“下一步”按钮时,它会显示第二个数字,依此类推。我如何构建应用程序来实现这一点?我可能需要在线程中运行生成器。但如何将其连接回GUI?

  6. 如何为每次提交将存储库历史记录拆分为一行?

    我正在尝试获取存储库的历史记录,但结果仅以单行文本的形式返回给我。

  7. 尝试在颤振项目上初始化Firebase时出错

    当尝试在我的颤振项目上初始化firebase时,我收到了这个错误有人知道我能做什么吗?应用程序分级Gradle插件Gradle项目颤振相关性我已经将firebase设置为Google文档已经在另一个模拟器上尝试过,已经尝试过创建一个全新的模拟器,已经在不同的设备上尝试过了,已经尝试了特定版本的firebase,已经尝试添加但没有任何效果,已经在youtube上看到了关于它的每一个视频,该应用程序在android和iOS两个平台上都抛出了这个错误

  8. 在unix中基于当前日期添加新列

    我试图在unix中基于时间戳列在最后一个单元格中添加一个状态列。我不确定如何继续。

  9. 麦克斯·蒙特利。我一直得到UncaughtReferenceError:当我在终端中写入node-v时,节点未定义

    如果这是您应该知道的,请确认:我已将所有shell更改为默认为zsh。当我在终端中写入node-v时,我一直收到“UncaughtReferenceError:nodeisnotdefined”。但它显示节点已安装。我是个新手,在这方面经验不足。

  10. 如何在前端单击按钮时调用后端中的函数?

    那么如何在后端添加一个新的端点,点击按钮调用这个函数。

返回
顶部