程序员经验分享-hwhale

Haskell Servant 和流媒体

2024-05-02

我正在尝试添加一个功能到我的servant服务器将从 Amazon S3 获取文件并将其流式传输回用户。 由于文件可能很大，我不想将它们下载到本地然后将它们提供给客户端，我宁愿将它们直接从 S3 流式传输到客户端。

I use Amazonka对于我对 S3 所做的事情，我可以获得 S3 文件的流作为Conduit sink.

但现在我不知道如何从Sink to EitherT ServantErr IO a.

谁能解释一下如何做到这一点或向我展示一些如何做到这一点的示例？


Servant 中没有任何东西可以开箱即用地执行此操作，但是所有需要的部件都可用。

在我们开始之前，我想如果您可以流式传输到接收器，则意味着您有一个源（gorsBody http://haddock.stackage.org/lts-4.2/amazonka-s3-1.3.7/Network-AWS-S3-GetObject.html#v:gorsBody of GetObjectResponse http://haddock.stackage.org/lts-4.2/amazonka-s3-1.3.7/Network-AWS-S3-GetObject.html#t:GetObjectResponse is a RsBody http://haddock.stackage.org/lts-4.2/amazonka-core-1.3.7/Network-AWS-Data-Body.html#t:RsBody，这是一个来源）

首先，Servant 为我们提供了添加对新返回类型的支持的可能性，通过创建一个新的实例HasServer http://hackage.haskell.org/package/servant-server-0.4.4.6/docs/Servant-Server-Internal.html#t:HasServer，所以我们可以服务EitherT ServantErr IO (Source ...)并让它流式传输。

要创建该实例，我们必须实现route :: Proxy layout -> Server layout -> RoutingApplication. Server layout，在这种情况下，仅意味着EitherT ServantErr IO layout, layout是我们想要服务器的源，因此它是返回源的函数（并且可能会因 HTTP 错误而失败）。

我们必须返回一个RoutingApplication https://hackage.haskell.org/package/wai-conduit-3.0.0.3/docs/Network-Wai-Conduit.html，这是（以延续风格）一个函数，它接受Request并返回一个RouteResult Response，这意味着要么是不匹配的路由错误，要么是响应。两个都Request and Response是标准的 wai，而不是 Servant，所以我们现在可以看看生态系统的其余部分，以了解如何实现它。

幸运的是，我们不必走太远：Network.Wai.Conduit https://hackage.haskell.org/package/wai-conduit-3.0.0.3/docs/Network-Wai-Conduit.html包含我们需要实现的内容route功能：responseSource接受状态值、一些响应标头和您的来源，并为您提供Response.

所以，要做的工作相当多，但我们需要的一切都在那里。寻找一个实例来源HasServer * (Get ...) http://hackage.haskell.org/package/servant-server-0.4.4.6/docs/src/Servant-Server-Internal.html#line-346可能有帮助。

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

Haskell

amazons3

servant

Haskell Servant 和流媒体 的相关文章

  • 应用交换律

    带有效果的应用程序编程 http staff city ac uk ross papers Applicative html麦克布莱德和帕特森的论文提出了互换法 u lt gt pure x pure f gt f x lt gt u 为了

  • 计算/获取分层数据的“级别”

    好吧 我真的不知道这是否是正确的标题 但我不知道如何称呼它 我的问题是关于我的作业 我现在已经工作了几个小时 主题是 函数式数据结构 我有点陷入困境 我不知道如何继续 所以我需要编写一个具有以下签名的函数 data Heap e t Hea

  • 使用 Haskell 的欧拉项目 #1

    import Data Set euler Int euler sum x x lt nums where nums Data Set toList Data Set union Data Set fromList 3 6 999 Data

  • 如何在 blaze-html 中渲染 blaze-svg 标记

    我想将使用 blaze svg 生成的 svg 图直接包含在使用 blaze html 生成的 html 中 两者都基于 blaze markup 所以我希望它很容易 diagram1 Svg diagram1 try1 Html try1

  • 从 S3 存储桶下载 300 万个对象的最快方法

    我尝试过使用 Python boto 多处理 S3cmd 和 J3tset 但都在努力解决 有什么建议 也许是您一直在使用的现成脚本或我不知道的其他方式 EDIT eventlet boto 是一个有价值的解决方案 如下所述 在这里找到了一

  • Haskell 真的是纯粹的吗（有任何语言可以处理系统外的输入和输出）吗？

    在谈到函数式编程中的 Monad 后 该功能是否真的使语言变得纯粹 或者它只是黑板数学之外的现实世界中计算机系统推理的另一张 免狱卡 EDIT 这不是有人在这篇文章中所说的火焰诱饵 而是一个真正的问题 我希望有人能用它来击倒我并说 证明 它

  • 如何在 TH 拼接中复制 'name 的行为

    考虑这个 Haskell 文件 LANGUAGE TemplateHaskell OPTIONS GHC fplugin Test Inspection Plugin module Text main where import Test I

  • 谁能解释一下 GHC 对 IO 的定义吗？

    标题非常自我描述 但有一个部分引起了我的注意 newtype IO a IO State RealWorld gt State RealWorld a 剥离newtype 我们得到 State RealWorld gt State Real

  • 如何获取常量内存中的统计数据

    我有一个函数 它会创建一些随机的数值结果 我知道 结果将是 a 小 a b 约 50 范围内的整数a b 我想创建一个执行上述函数 1000000 次的函数 并计算每个结果出现的频率 该函数使用随机生成器来生成结果 问题是 我不知道如何在常

  • “反向”使用 Maybe Monad

    假设我有很多功能 f a gt Maybe a g a gt Maybe a h a gt Maybe a 我想按以下方式组合它们 如果 f 返回 Nothing 则计算 g 如果 g 返回 Nothing 则计算 h 如果其中任何一个计算

  • 计算两点之间的距离（Haskell）

    给定两个元组的输入 我希望能够使用以下公式计算两点之间的距离 距离 sqrt x1 x2 2 y1 y2 2 所以我希望函数调用和输出如下所示 gt distance 5 10 3 5 5 385 当我尝试运行下面的代码时 它告诉我输入 w

  • 将 Either 列表转换为其中包含列表的 Either 列表

    我是 Haskell 的初学者 我正在编写一些使用 Haskell 的代码Either https hackage haskell org package base 4 9 0 0 docs Data Either html用于错误处理 E

  • Haskell 中的相互递归求值器

    Update 我已经添加一个答案 https stackoverflow com questions 3524485 mutually recursive evaluator in haskell 4504200 4504200这描述了我的

  • 如何组合过滤条件

    过滤器类函数接受一个条件 a gt Bool 并在过滤时应用它 当您有多个条件时 使用过滤器的最佳方法是什么 使用了应用函数 liftA2 而不是 liftM2 因为出于某种原因我不明白 liftM2 在纯代码中如何工作 liftM2 组合

  • AWSS3GetObjectRequest ifModifiedSince 不起作用

    建设为iOS 7 建立在Xcode 6 1 使用亚马逊SDKAWSiOSSDKv2 2 0 12 测试于iPhone 5s 和 iPad 2 我正在使用适用于 iOS 的 Amazon SDK 从我的 Amazon S3 存储桶下载图像 下

  • 对元组列表进行排序的函数 - Haskell

    抱歉 这个简单的问题只是我对 haskell 非常陌生 我正在尝试编写一个函数 order 它将对另一个函数 Frequency 生成的元组列表进行排序 频率计算列表中不同元素的数量 a给出一个这样的结果 比如 gt 频率 aabbbccc

  • 反应性香蕉时间延迟

    我已经查阅了文档反应香蕉 http hackage haskell org package reactive banana 而且我找不到指定明确时间延迟的方法 举例来说 我想采取Event t a并将其所有发生的事件移至未来 1 秒 或获取

  • 如何使用 Rails 应用程序中的 s3 在存储桶之间复制文件？

    我目前正在开发一个 Rails 应用程序 尝试将视频从 s3 中的一个存储桶复制 移动到另一个存储桶 但是我在 Rails 应用程序上不断收到代理错误 502 在杂种日志中 它显示 无法分配内存 一旦发生此错误 应用程序就会终止 我们必须重

  • Haskell 和 Idris 之间的区别：类型宇宙中运行时/编译时的反映

    因此 在 Idris 中 编写以下内容是完全有效的 item b Bool gt if b then Nat else List Nat item True 42 item False 1 2 3 cf https www youtube

  • 为什么以下内容会并行运行而不是顺序运行？

    给定以下函数evalPair parPair and deepSeq分别 evalPair Strategy a gt Strategy b gt Strategy a b evalPair sa sb a b do a lt sa a b

随机推荐

  • std::type_info::hash_code() 的唯一性和“应该”的含义

    是否意味着保证相同std type info hash code 值意味着相同的类型 Cplusplus com http www cplusplus com reference typeinfo type info hash code 似

  • 浮动操作按钮未显示在 recyclerview 上（位于 DrawerLayout 内）

    我正在尝试通过 recyclerview 获取 FAB 在我的情况下 它将覆盖整个屏幕 即使 recyclerview 为空 FAB 也不会显示 以下是我的 xml 代码

  • OT 和 CRDT 之间的区别

    有人可以简单地向我解释一下操作转换和 CRDT 之间的主要区别吗 据我了解 两者都是允许数据在分布式系统的不同节点上无冲突地收敛的算法 在哪种用例中您会使用哪种算法 据我了解 OT主要用于文本 而CRDT更通用 可以处理更高级的结构 对吧

  • 以有效的方式找到最近点

    我在 2d 平面上有一个点 例如 x0 y0 和一组 n 点 x1 y1 xn yn 我想在 a 中找到距离 x0 y0 最近的点比尝试所有要点要好得多 有什么解决办法吗 我还应该说我的观点是这样排序的 bool less point a

  • 如何使用增量值向 Pyspark 中的 DataFrame 添加列？

    我有一个名为 df 的 DataFrame 如下所示 Atr1 Atr2 Atr3 A A A B A A C A A 我想向其中添加一个具有增量值的新列并获取以下更新的 DataFrame Atr1 Atr2 Atr3

  • 根据 iOS 6 通讯录使用文档，第 22 条规则

    根据 iOS6 的文档 应使用 ABAddressBookCreateWithOptions 创建地址簿 它还表示如果调用者无权访问数据库 则此方法将返回 null 但是 访问是通过调用 ABAddressBookRequestAccess

  • 通用搜索 - 重定向到自定义屏幕

    我创建了一个自定义屏幕 它是客户屏幕的副本 问题是 当我们在通用搜索中输入客户 ID 时 如何重定向到自定义屏幕而不是客户屏幕 请查看我们自定义屏幕的图形代码 public class CustomScreen BusinessAccoun

  • Unity3D 不安全代码需要指定“unsafe”命令行选项

    我在用Unity3D 4 3并打电话给DLL我创造的 当尝试调用它唯一的函数时 这是 void GetModelReferences int nVertices float vertices int nTriangles int trian

  • 在 CentOS 6.4 上的 apache 2.0 虚拟主机中创建子域

    我需要在网络服务器上创建子域阿帕奇2 0 CentOS 6 4 PageSpeed Apc 我没有 DNS 服务器 我需要使用虚拟主机 我的代码 NameVirtualHost xx xx xx xx

  • 确定已编译Lua的编译器版本

    我有一些已编译的 LuaQ 我需要确定用于编译它的确切版本 有什么可能的方法吗 编译的脚本在文件开头有一个标头 4 bytes signature x1bLua 1 byte version 0x51 1 byte format 1 byt

  • 如何在 Java 中将 hashmap 转换为 JSON 对象 [关闭]

    Closed 这个问题需要细节或清晰度 help closed questions 目前不接受答案 如何在 Java 中将 hashmap 转换或转换为 JSON 对象 然后再次将 JSON 对象转换为 JSON 字符串 您可以使用 new

  • 不分配内存的重复排列

    我正在寻找一种算法来生成列表中重复 4 个元素 长度 2 1000 的所有排列 Java实现 http en literateprograms org Permutations with repetition 28Java 29 问题是上面

  • 将数组传递给 include() javascript

    我试图找出一个字符串是否包含存储在数组中的多个字符串 includes 所以我尝试过 let string hello james console log string includes hello james 但它被返回为false 当我

  • javascript RegExp 的奇怪行为：相同的正则表达式产生不同的结果[重复]

    这个问题在这里已经有答案了 可能的重复 为什么 Javascript 中带有全局标志的 RegExp 会给出错误的结果 https stackoverflow com questions 1520800 why regexp with gl

  • 通过 jclouds 使用 AWS (S3) - 如何承担角色

    使用普通身份验证凭据时 我可以执行以下操作 ContextBuilder newBuilder aws s3 credentials keyId key buildView BlobStoreContext class 访问 S3 的 Bl

  • 如何将 git 存储库转换为 Mercurial？

    我一直在使用 git 作为源代码存储库开发 java 应用程序 我想与其他 java 开发人员分享该项目 hg 似乎是他们最常用的 我的问题是如何将 git 存储库转换为 hg 如果我尝试谷歌搜索 将 git 转换为 hg 并且每次搜索命中

  • 以编程方式将图像添加到RelativeLayout

    我想通过代码添加各种相对布局到线性布局 每个相对布局由以下部分组成 左侧的图像视图 右侧旁边的文本视图 正好在中间 以及右侧的另一个图像 我必须使用从数据库读取的数据来添加它们 它必须使用relativelayout 因为我想在图像上使用一

  • 如何在 C++ 中将方法结果作为参数传递给基类构造函数？

    我试图实现这样的目标 class Base public Base string S class Derived Base public int foo string bar return stringof foo actually som

  • 按属性值对结构体数组进行排序

    我在 C 中有一个任务 使用 qsort 对结构进行排序 struct user enum SEX m f sex char name 32 char phonenr 32 typedef struct user User 用户将存储在一个

  • Haskell Servant 和流媒体

    我正在尝试添加一个功能到我的servant服务器将从 Amazon S3 获取文件并将其流式传输回用户 由于文件可能很大 我不想将它们下载到本地然后将它们提供给客户端 我宁愿将它们直接从 S3 流式传输到客户端 I use Amazonka

热门标签