1回答
希望使用python脚本访问orion数据(不使用curl或Postman)。下面显示了我的orion.py脚本中的python脚本：
import json
import requests
orion_endpoint="some-endpoint"
url_query=("orion_url" % (orion_endpoint))
body_dict = {
'entities': [
{
'type': 'AirQualityObserved',
'idPat
浏览 3提问于2019-03-13得票数 2
回答已采纳
我正在尝试更新Red 7系统，但由于以下依赖消息无法更新：
Error: Package: Trac-1.0.12-1.noarch (@/Trac-1.0.12-1.noarch)
Requires: /bin/python
Removing: python-2.7.5-34.el7.x86_64 (@rhel-7-server-rpms)
Not found
Updated By: python-2.7.5-48.el7.x86_64 (rhel-7-server-rpms)
浏览 0提问于2017-06-28得票数 1
我想发送一个退订请求到SNS主题的电子邮件，因为我是新的Lambda，你能让我知道什么函数可以在这里使用，我有电子邮件地址和主题arn作为传入参数。我正在使用python 3.8 boto 3。 提前谢谢。
浏览 35提问于2021-02-11得票数 1
当python客户端接收到这些事件时，我创建了一个打印服务器发送事件的基本进程。稍后，我将根据未来的数据更改模块的状态。大多数示例用于测试python端作为事件发射器。我想使用python作为客户端。
#subscriber.py
class Subscriber():
def __init__(self):
def start_listening(self):
messages = sseclient.SSEClient(SOME_URL_THAT_PUBLISHES_EVENT_STREAM)
for event in messages
浏览 18提问于2021-12-10得票数 1
1回答
我已经在mac x (el capitan)上安装了python3.5。我想在python中导入py鲨模块，但是我得到了错误。我安装了吡鲨鱼的需求，例如(日志簿、lxml、trollies、py)，但我无法导入pyshark模块。
pip3 list >>
syncio (3.4.3)
futures (3.0.3)
Logbook (0.12.3)
lxml (3.5.0)
pip (7.1.2)
py (1.4.30)
pyshark (0.3.6)
setuptools (18.2)
trollius (2.0)
导入pyshark模块错误：
>>> imp
浏览 5提问于2015-12-07得票数 1
回答已采纳
我使用pubnub和python。我有一些用python编写的测试环境，我正在编写python代码，以便将pubnub客户端订阅添加到通道和取消订阅。在服务器中，我检查服务器是否获得连接并留下消息(我使用的是存在通道)。
问题是，当线程死后，我将不会收到留言，而且在python代码中没有看到任何取消订阅调用来执行显式取消订阅。
有什么想法吗？
谢谢。
我的代码如下所示：
def main(user_id,channel_name):
t = Thread(target=rt_subscribe,args=(user_id,channel_name))
def
浏览 2提问于2014-04-17得票数 1
回答已采纳
1回答
我有Perl脚本，目前做一些后台工作，我需要在Python中获得web前端的结果。我想使用JSON来做这件事，或者有些类似的事情，但我不知道该如何做。
我的JSON看起来可能是这样..。
{
"array": [
1,
2,
3
],
"boolean": true,
"null": null,
"number": 123,
"object": {
"a": "b",
"c": "d",
浏览 1提问于2014-05-15得票数 1
回答已采纳
我有一个下面的python代码，它在python - python PUB/SUB ZeroMQ ( pyzmq )场景中成功工作。
我可以通过c++订阅这个python服务器吗？
我还添加了一个c++客户端代码，但它不起作用。
Python：
def send_array_and_str(socket, img, string, flags=0):
global count
print(count , " sended")
## numpy array gönderirken shape bilgilerini de msg olarak eklem
浏览 6提问于2020-04-17得票数 1
可以使用python代码创建azure订阅吗？如果可能的话，怎么做？
我想找点这样的东西：
def create_subscriptions():
response = client.create_subscriptions(
------------------,
------------------
)
return response
浏览 0提问于2018-09-03得票数 0
1回答
Python paho-mqtt 有没有人能告诉我如何读取所有连接到代理的客户id？例如:我订阅了某个主题，我想获取所有连接到同一主题的客户id。
浏览 14提问于2020-06-15得票数 0
如果消息被发送到mqtt代理中的主题，我想通过Python了解这个主题。为了使用client.subscribe ()，我必须手动输入一个主题，因此需要在client.subscribe ()之前动态地了解主题。有没有办法知道经纪人的话题是什么？
浏览 4提问于2017-03-08得票数 1
回答已采纳
1回答
我正在尝试制作一个c程序服务器，它通过nng发布图像，而python客户端通过pynng订阅图像。
由于某些原因，我不能连接这两个部分，我不知道为什么。C/C++-程序编译和运行良好，python程序也是如此，但是在C/C++程序上发布了一些东西，在python客户机上没有收到任何消息。客户端和服务器在同一台机器上运行。以下是服务器的C/C++代码：
#include <nng/nng.h>
#include <nng/protocol/pubsub0/pub.h>
int main(int argc, char* argv[]){
nng_socket s
浏览 5提问于2020-05-08得票数 1
回答已采纳
我正在尝试编写一些python服务，这些服务将部署在kubernetes上，它的功能类似于由google.storage.object.finalize操作触发的云函数，并侦听存储桶。实际上，我需要用以下参数替换创建的云函数： --trigger-resource YOUR_TRIGGER_BUCKET_NAME
--trigger-event google.storage.object.finalize 然而，我在网上找不到任何关于如何做到这一点的资源。对于kubernetes中部署的一些python脚本来说，观察存储桶上执行的操作并在新文件写入存储桶时执行某些操作的最佳方式是什么？谢谢
浏览 10提问于2021-09-29得票数 0
回答已采纳
最近，我使用python和redis构建了一个智能的混乱驱动项目。我使用一个线程对redis通道(这里称为消息线程)进行子处理；使用一个定时器线程；使用一个辅助线程；当消息线程得到足够多的消息时，它会将一个任务发送给worker。我使用 redis -py与redis通信。
消息线程：
订阅红皮书；
while True:
get message;
if len(messages)>threashold: post task to Worker
工作线程：
while True:
wait task event;
do task; //this may b
浏览 0提问于2013-08-08得票数 1
回答已采纳
1回答
我有一个使用ZMQ的python消息传递应用程序。每个对象都有一个PUB和一个子队列，它们相互连接。在某些特定情况下，我希望在子队列中等待特定的消息，而将我不感兴趣的消息留给以后处理。
现在，我正在获取所有消息，并将那些我对Python队列不感兴趣的消息排队，直到我找到我等待的消息。但他的意思是，在每个处理路由中，我需要首先在Python队列中检查旧消息。有没有更好的方法？
浏览 5提问于2012-11-02得票数 2
1回答
目前，我刚开始在Open中使用MPI用于python，我有以下问题：
当我尝试使用mpiexec -np 7 mpitest.py运行一个简单的脚本时，我有以下错误：
系统中没有足够的插槽来满足应用程序请求的7个插槽: python要么为应用程序请求更少的插槽，要么提供更多的插槽供使用。
我不明白，我有一台12处理器的计算机，每个套接字有6个核心(每个处理器有一个套接字)，所以这意味着我可以运行72个线程，但是OpenMPI只能运行6个线程。
知道如何利用所有处理器吗？
浏览 1提问于2017-09-22得票数 1
1回答
不想更改每个azurecli任务的所有订阅名称，有什么方法可以将其添加为管道顶部的参数，例如azureSubscription='MYSUB‘吗？那就叫吧
trigger:
none
schedules:
- cron: "0 12 * * *"
displayName: Daily build
branches:
include:
- dev
always: true
pool:
vmImage: "windows-latest"
variables:
- group: ml-environment
浏览 2提问于2022-10-05得票数 -1
回答已采纳
1回答
我正在尝试使用我在媒体上找到的一篇文章创建一个使用python的gmail帐户。这篇文章是：
这是我的代码：
def generate_gmail(ID: int):
# access the API
url = "https://temp-gmail.p.rapidapi.com/get"
querystring = {"id":ID,"type":"alias"}
headers = {
'x-rapidapi-host': "temp-gmail.p.rapidapi.c
浏览 12提问于2022-03-01得票数 0
我可以将消息从Python后端(在VM实例上)推送到主题&参见发布/订阅主题上的消息。但是没有使用angular从主题中提取数据的代码。我想提取这些数据并将其显示给Angular UI。你能帮我弄一下这个吗？
浏览 3提问于2021-01-08得票数 2
我真的很喜欢中与Ruby相关的主题链接的格式和类型。有没有活动的Python的等价物？有一个，但我认为它差不多已经死了。
我真的不喜欢，因为上面有很多非Python的东西，而且很少有帖子的摘要。
浏览 0提问于2009-01-17得票数 6
回答已采纳
3回答
有没有消息传递解决方案(最好支持Python)，我可以像邮箱一样使用，例如，从任何给定的队列中检索消息，而不必订阅？我认为消息队列可以工作，但我必须重复订阅，从队列中抓取消息，然后取消订阅，这听起来并不是最优的。
浏览 1提问于2011-03-30得票数 0
回答已采纳
我正在使用GCP来发送和接收JSON数据，Pubsub有一个特性可以从10分钟到7天(根据官方文档)保留一条消息。有没有办法从Pubsub删除一条拉出的消息？如果不是，那么为什么我们说Pubsub是一种“排队技术”，而我们却不愿意从违反基本队列属性的消息存储中删除消息呢？
我使用python客户端库来编写脚本。
浏览 0提问于2019-03-18得票数 3
回答已采纳
我有一个简单的python函数，在这里，我只需要从公共主题中获取输入，然后打印出来。
import base64,json
def hello_pubsub(event, context):
"""Triggered from a message on a Cloud Pub/Sub topic.
Args:
event (dict): Event payload.
context (google.cloud.functions.Context): Metadata for the event.
"&
浏览 2提问于2020-09-23得票数 2
回答已采纳
1回答
你好，我是Python和AWS SNS服务的新手。我想开发一个Python实用程序，它将执行订阅者和发布者的角色，以自动化一些模拟。我被困在我需要设计端点的地方，它将充当SNS消息接收器。你们能在这个话题上给我指点一下吗？
浏览 3提问于2016-06-22得票数 1
在python2上自动缩放的App上，请求处理程序的最大超时时间为60，对于普通的http请求，对于任务队列请求，则为10分钟。
我找不到任何关于公共任务的信息。他们也有像任务队列/云任务那样的10分钟超时吗？
此外，似乎谷歌正在修改他们的文档，在python3中，所有请求都有10分钟的超时时间：
但是如果你去他们的医生那里找python3的cron，上面写着An HTTP request invoked by cron can run for up to 60 seconds
浏览 1提问于2020-01-16得票数 1
回答已采纳
有时，当我不能使用Python时，我会感到难过。在Python中，我处理一个参数数组，将它们解压缩如下：
name, handle, parent_handle, [left, top, right, bottom], showing, scrollable = data
我现在必须在Objective中对NSArrays进行同样的操作。我是否注定要执行以下11行：
NSString *name = (NSString *)[data objectAtIndex:0];
NSNumber *handle = (NSNumber *)[data objectAtIndex:1];
//....
浏览 2提问于2013-09-10得票数 8
回答已采纳
2回答
我有发布/子主题、请求订阅和数据管道，它们使用GCP发布/子库的python和NodeJS实现来提取消息。
我有一个没完没了的有规律的流媒体工作量和临时工作负荷。我想在需要的时候立即优先处理临时工作负载。
我该怎么做？
为每个管道创建一个附加的发布/子主题似乎是一个错误的解决方案。必须有另一种方法来优先处理临时工作负载。
浏览 16提问于2022-06-01得票数 0
1回答
我正在使用docker和redis来了解docker中的多容器是如何工作的。我正在使用下面的简单flask应用程序，它有一个发布和订阅code.However，我看不到订阅者收到的任何消息 import redis
from flask import Flask
app = Flask(__name__)
client = redis.Redis(host="redis-server", decode_responses=True)
def event_handler(msg):
print("Handler", msg, flush=True
浏览 48提问于2020-08-26得票数 0
回答已采纳
我有一个基本的MQTT问题:如果我有一个代理，我不能自己配置，但可以匿名发布或订阅，发布者是否可以在该主题上定义允许的客户端？
例如，对于蚊子，我可以定义ACL文件，但只能在代理站点上定义。
如果不可能，用python加密已发布数据的最佳方式是什么？
浏览 18提问于2020-03-12得票数 0
回答已采纳
2回答
我在我的项目中使用ROS，我需要不时地发送一条信息。我的职能是：
void RosNetwork::sendMessage(string msg, string channel) {
_mtx.lock();
ros::Publisher chatter_pub = _n.advertise<std_msgs::String>(channel.c_str(),10);
ros::Rate loop_rate(10);
std_msgs::String msgToSend;
msgToSend.data = msg.c_str();
c
浏览 3提问于2015-08-04得票数 2
回答已采纳
我正在编写一个脚本，该脚本当前访问Azure虚拟机的详细信息。这是我到目前为止掌握的代码：
"""
Instantiate the ComputeManagementClient with the appropriate credentials.
@return ComputeManagementClient object
"""
def get_access_to_virtual_machine():
subscription_id = key.SUBSCRIPTION_ID
credentials = Def
浏览 3提问于2021-06-02得票数 5
回答已采纳
我正在编写一个python脚本(实际上是一个Calibre食谱)来检索我的readlist中特定标签或类别下的所有项。我可以从类别中检索整个项目，但我喜欢逐个提要检索项目，所以我需要一种方法来列出特定类别下的提要文件(就像Google Reader UI在您单击文件夹时所做的那样)。我找不到这样做的API。有什么建议吗？谢谢。
浏览 4提问于2012-03-22得票数 0
我们是IT方面的一些学生，我们正在研究NAO (所以我们是非常初学者)。我们希望用NAO摄像机在地面上实现线状探测。为此，我们开发了Choregraphe中的Python，但是我们无法正确地订阅和取消订阅"ALVideoDevice“。
下面是Python脚本框的代码：
import sys
import numpy as np
import cv2
from naoqi import ALProxy
import PIL
from PIL import Image
from PIL import ImageDraw
from PIL import ImageFont
import v
浏览 0提问于2018-06-12得票数 1
回答已采纳
1回答
我们已经在GCE上安装了Redhat 7实例，它将承载一个SAS安装。目前，由于Redhat服务器未注册，我们被困在SAS安装过程中。
命令“订阅-管理器版本”返回以下内容：
server type: This system is currently not registered.
subscription management server: 0.9.51.24-1
subscription management rules: 5.15.1
subscription-manager: 1.19.21-1.el7
python-rhsm: 1.19.9-1.el7
为什么我们的Redhat实例
浏览 0提问于2017-10-12得票数 0
回答已采纳
当我介绍一个包含以下pytest.ini的文件时
[pytest]
python_files = *.py
然后我得到了下面的崩溃：
$ python -m pytest a.py
========================================== test session starts ==========================================
platform linux -- Python 3.9.5, pytest-7.1.0, pluggy-1.0.0 , configfile: pytest.ini
collected 0 items
浏览 11提问于2022-04-05得票数 0
回答已采纳
考虑一层N个订阅者，所有订阅者都使用相同的队列名称和路由键值连接到直接交换。这创建了一个负载平衡系统，其中以循环方式将入站消息发送给1个订阅者。这对于处理横向扩展问题非常有效，因为随着负载的增加，可以添加更多的订阅者，如果需要，可以在以后撤回订阅者。
现在考虑能够向该层中的所有订阅者发送消息的要求，而不需要知道有多少订阅者(例如，“重置状态”或“立即关机”管理消息)。有没有办法在rabbitmq中做到这一点？如果这不可能，有没有更好的方法？
我的环境是使用amqplib的Python。
浏览 2提问于2010-07-01得票数 0
回答已采纳
我是卡夫卡世界的新手，我试图在python中为卡夫卡的消费者做以下的事情
获得所有卡夫卡主题的列表。获得消费者已订阅的主题列表。订阅新主题(尚未订阅)。
注:我可以使用任何一个汇合卡夫卡/卡夫卡-python库来实现这一点。
任何帮助都将不胜感激。
浏览 1提问于2021-04-21得票数 0
回答已采纳
我正在为我的覆盆子皮开发一个浏览器NFC解决方案。我在Chrome浏览器中开发了一个java小程序。java applet正在与我的nfc读取器一起工作。每次标记我的卡时，他都会调用javascript函数，并将我的card ID发送到这个javascript函数。我的身份证上有警报。
Java非常繁重，内存开销很大。我喜欢的是使用python而不是java。python脚本需要与相同。
读我的NFC卡
将Card id发送到javascript函数
用我的标签ID发出警报。
等下一张牌再做同样的事..。转到1
我发现的是像这样的python，它可以轻松地安装一个web
浏览 1提问于2013-01-10得票数 0
我正在使用版本1.0.0。我有一个主动订阅，不断收到应该重定向到天鹅座的通知。
我担心的是，上周四，这项订阅确实到期了。理论上，当订阅不断向其订阅者发送通知时，过期日期将被更新。那么，有谁知道活跃订阅为什么会过期呢？
我就是这样做订阅注册的：
(curl 172.21.0.33:1026/v1/subscribeContext -s -S --header 'Fiware-Service: xxxx' --header 'Fiware-ServicePath: /xxxx/xxxx' --header 'Content-Type: application
浏览 0提问于2016-06-14得票数 1
回答已采纳
我正在使用Fiware cygnus订阅orion上下文代理实体。可以用一个脚本订阅所有的上下文更新吗？我不想一个接一个地做。以下是订阅的示例：
(curl 192.168.1.79:1026/v1/subscribeContext -s -S --header 'Content-Type: application/json' --header 'Accept: application/json' --header 'Fiware-Service: test' --header 'Fiware-ServicePath: /testPath
浏览 0提问于2015-08-05得票数 4
刚接触python并从事项目工作。我目前正在试图从这个链接中提取美国可用的充电器站列表，使用Python代码：。看起来有些巧妙的代码已经过时了，我在更新它时遇到了问题，特别是下面的upercharger_locations.keys()0:10脚本导致了错误"TypeError：'dict_keys‘对象不可订阅“。
import chart_studio.plotly as py
import plotly.figure_factory as ff
data_matrix = [['Location ID', 'Latitude', '
浏览 7提问于2022-02-04得票数 0
2回答
我正在进行Braintree订阅搜索，以检索与这些ID相关联的客户ID和订阅价格。在我的代码中，我遵循的建议。
下面是我代码的摘录：
gateway = braintree.BraintreeGateway(
braintree.Configuration(
environment=braintree.Environment.Production,
merchant_id= 'our_merchant_id',
public_key='our_public_key',
private_key
浏览 0提问于2018-09-25得票数 2
回答已采纳
我对Autobahn和crossbar.io很陌生。到目前为止，我尝试创建一个onEvent函数，它可以同时用于订阅不同的主题。但是，我需要这个函数来知道哪条消息来自哪个主题。然后，我发现在details函数中有一个subscibe参数，它包含一个topic参数。但是，在接收消息时，此参数总是显示None。有人能告诉我怎么做正确的设置吗？这是否可以在Autobahn，x，JS和Autobahn\Python中实现？
(在我的场景中，我使用精确匹配-uri-方法订阅了几个主题。希望任何人提供的方法都能在这种条件下工作)
谢谢
浏览 4提问于2015-10-21得票数 0
回答已采纳
1回答
我的头脑在旋转，我只是想要一种用户可以订阅我的桌面应用程序的方式。我的基本需求：
用户注册并加入订阅。
一旦用户加入付费订阅，他们就可以访问python tkinter应用程序。
如果用户退出订阅，则不再允许他们访问。
我已经从许可证密钥转到了沙箱Braintree，但我仍然不知道该做什么，有人知道如何将与python集成，还是有其他方法？
谢谢你提前提供帮助
浏览 2提问于2020-07-23得票数 1
回答已采纳
我正在使用下面的代码来进行日记化。订阅后，我不会让任何payment_intent收费。我怎样才能向顾客收费
# https://stripe.com/docs/api/subscriptions/object?lang=python
def create_stripe_subscription(customer_id, price_id):
stripe.api_key = STRIPE_API_KEY
res = stripe.Subscription.create(
customer=customer_id,
浏览 10提问于2022-05-12得票数 0
我有一个MacBook Pro(10.6.5)，并试图安装使用pip。请注意，我对python世界非常陌生。顺便说一下，我使用了以下命令：
pip install --user scipy
我犯了以下错误：
Command python setup.py egg_info failed with error code 1 in /Users/hk3/build/scipy
Exception information:
Traceback (most recent call last):
File "/Users/hk3/Library/Python/
浏览 1提问于2012-07-04得票数 0
1回答
我有一个名为(train)的消息队列，每当向它添加任何内容时，我都想创建一个新队列或执行一些操作。因此，我将侦听器附加到队列中，并从侦听器中启动新队列。但问题是我无法从侦听器启动队列，因为它会抛出一些错误。
'''
This function will be called when we add anything to message_queue.
'''
def notify_when_added(event):
res = event.item
if res.status == Activity.train:
浏览 1提问于2019-08-27得票数 0
我想获得订阅者( SUB )套接字的订阅密钥在设置之后。
假设我有以下套接字：
import zmq
ctx = zmq.Context.instance()
sub_sock = ctx.socket(zmq.SUB)
sub_sock.bind("tcp://127.0.0.1:6667")
sub_sock.setsockopt(zmq.SUBSCRIBE, "foo1".encode('ascii'))
我想做的是这样的事情(伪代码)：
sub_key = sub_sock.get_sub_key().decode("ascii&
浏览 1提问于2018-06-28得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
