1回答
我有两条管道，"gameEngineEvents“和"userEvents”，它们使用等价的pubsub主题。一个userEvent可能有一个或多个gameEngineEvents。那么，只在数据流中做这样的事情是可能的吗？
浏览 5提问于2017-08-09得票数 0
回答已采纳
ADF管道和ADF数据流有什么区别？为什么管道和数据流支持的汇/源是不同的？是否有可能创建一个管道来读取来自源的数据、筛选、使用连接并将数据存储到没有数据流的接收器中？请让我知道。
浏览 0提问于2020-05-14得票数 8
回答已采纳
我目前正在使用Google Cloud Dataflow和Apache Beam来消费来自两个不同Kafka集群中的Kafka主题的消息，这两个集群包含相同的主题名称，但主题中的数据不同。Kafka集群是分开的，因为它们包含来自不同区域的数据。
我只是想知道，是否可以通过在单个KafkaIO.read数据流管道
浏览 23提问于2020-05-13得票数 0
我一直在尝试在两个不同的管道之间共享tfstate文件。我需要使用来自不同管道的terraform部署infra，并使用来自不同管道但具有相同tfstate文件的terraform部署应用程序 我能够使用不同的tfstate文件，并使用一个管道部署infra，使用</
浏览 17提问于2021-10-18得票数 0
我们在一台服务器上托管了Hazelcast集群，在同一区域的不同服务器上的不同应用程序使用Hazelcast Jet客户端实例通过管道聚合来自Kafka源的数据。在此设置中，Jet客户端实例是否发送从Kafka源Hazelcast集群接收的数据，这将涉及大量IO，或者当我们创建管道时，Hazelcast集群本身创建到Kafka的连接，此连接来自J
浏览 22提问于2019-01-25得票数 0
我有6个数据工厂。其中4个在同一地区，2个在不同的地区。它们位于不同的资源组中。在其中一个(让我们称它为adf-mgmt)中，我创建了一个管道(sendmail)，它在发生错误时发送电子邮件；https://www.mssqltips.com/sqlservertip/5718/azure-data-factory-pipeline-email-notification--part-1/ 我可以使用来自
浏览 20提问于2020-08-25得票数 0
回答已采纳
这就是当前的情况:在Azure Dataset中，我有越来越多的59个不同的数据集。每个数据集来自不同的DAta湖容器和文件夹。我希望将这59个数据集在datasets中的单个管道中复制到不同的SQL表中。是否可以只创建一个管道来读取所有不同的59个数据集并将它们复制到sql
浏览 8提问于2022-10-19得票数 0
3回答
我想知道如何使用像Windows上的Unix域套接字那样的东西。
行为是:一个进程将是一个“服务器”，接收来自其他进程的连接，它可以保留和使用来自不同进程的连接，就像TCP套接字所做的那样。IP套接字不是一种解决方案，因为它需要选择端口，来自其他应用程序的进程可能需要所选的端口，并且在网络中可能会看到打开的端口。我不知道命名管道
浏览 0提问于2012-01-27得票数 16
回答已采纳
3回答
我想订阅一个可观察的使用异步管道的角。但是，管道中的数据可以来自不同的数据源，而管道可能因数据源的不同而不同。现在实现它的方式不起作用，因为我覆盖this.data$的第一个值，因此源A永远不会被订阅。
根据过滤器的不同，是否有可能将<em
浏览 3提问于2019-12-23得票数 3
回答已采纳
嗨，我正在使用netty 4示例(qotm)创建一个UDP服务器，其中使用了'Bootstrap‘。该类不允许对处理程序进行管道处理。我是不是遗漏了什么？
浏览 0提问于2012-11-28得票数 2
我正在进行一个项目，它接收来自多个客户端的请求，通过pubsub，数据流管道将以流模式进行处理，发出响应。每个流程都有一些共同的逻辑，也有从/到BigTable/BigQuery的读/写。对于每个输入，使用一个接收来自不同客户端的输入的单一管道(包括开发和维护方面)有什么优缺点？
浏览 0提问于2016-12-20得票数 2
回答已采纳
我想在Azure中创建一个包含来自多个源的信息的数据仓库。输入数据来自不同的APIS，我想使用python访问它们，输出应该存储到Warehouse中。这个过程应该每天更新。我已经阅读了很多来自Azure的文档，但是我不能理解我需要如何设计这个过程。
第一个问题是:应该在哪里创建python进程，以便从不同的API收集数据？在Azure数
浏览 0提问于2017-12-13得票数 2
我有一个C程序，它通过(Linux)管道接收来自另一个程序的数据。我希望在编写任何数据之前，如果管道关闭，程序的行为就会有所不同。这样做的自然方法是尝试从管道中读取数据，并检查是否获得EOF，但如果有可用的数据，则会消耗管道中的一些数据，而且(据我所知)无法将数据“返回”到管道</em
浏览 0提问于2020-08-13得票数 5
回答已采纳
我正在尝试创建一个带有选择框下拉菜单的管道，用于过滤json数据中的列表。我已经创建了一个带有选择框管道的管道。我不能让我的过滤器在管道中工作。请帮帮忙。positionOpt of positionSelect" [value] = "sel">{{positionOpt.name}}</option>SelectBox选项字段<e
浏览 0提问于2017-09-15得票数 6
回答已采纳
1回答
就主题而言，该数据集包含有关植物、动物和无关内容的文本。首先，我使用分类器(线性支持向量机)来标记每个片段的类别(svm_gen: 0-无关，1-植物，2-动物)。工作正常，没有问题。现在每个类别都有子类别，我也想用自己的算法对每个子类别进行分类。我如何有选择地将各自的管道应用于预先分类的变量，而不拆分，然后再次追加数据集？
如前所述，我可以基于预分类拆分数据集，在新的熊猫数据帧上
浏览 2提问于2019-05-14得票数 0
我正在尝试部署一个具有复制数据管道的azure数据工厂，该管道从一个或多个已部署的/ on-prem文件系统路径中提取文件，并将它们转储到blob存储中。文件系统上的源文件路径可以跨越多个不同的驱动器(例如- C:\fileshare1与D:\fileshare2)，并且可以包括通过UNC路径引用的网络位置(例如- \localnetworkresource我想配置一个本地文件系统连接和源数据</e
浏览 7提问于2019-07-10得票数 0
我正在创建一个管道，将一系列csvs装入Azure SQL数据库该列的存在将需要在管道中增加一个步骤(使用RemovedData == true从数据库中删除任何行)。ADF或(带有<e
浏览 1提问于2019-04-02得票数 0
回答已采纳
我试图在Google数据融合中自动化一些管道执行(目前我们正在使用6.1.4和6.4.0 )。此时，我们正在通过PUT API调用向DF注入一些“运行时args”。我的问题是关于设置参数来修改配置部分。例如，我们目前正在使用"system.profile.name“参数告诉这个管道使用特定的配置文件，请参阅：。我知道，在导入管道之前，可以通过修改UI或在管道模板(json)中设置不同<em
浏览 2提问于2021-04-14得票数 0
1回答
我正在使用Apache处理来自不同资源的数据，并且为每个数据流创建了独立的管道。我想结合这些数据来进一步处理。有没有方法可以聚合数据并将其写入单个文件。数据以流文件属性的形式显示在Nifi中。
浏览 2提问于2016-11-17得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
