Re: [D] Python Producer Message to InfluxDBv2 sink connector with [pulsar]

2024-04-23 Thread via GitHub 


GitHub user smuehlmann edited a discussion: Python Producer Message to 
InfluxDBv2 sink connector with

Hi,

i have problems to send a message with a python producer which should be 
processed by an InfluxDBv2 sink connector. Especially the message content / 
payload in combination with the used producer schema is my problem. The Pulsar 
Version is 3.2.2.

With java code it is possible. 

Java class:

 public class Device  {
public String measurement;
public long timestamp;
public Map tags;
public Map fields;
   }

Set values:

Device device = new Device(); 
   device.measurement = "test5";
   device.timestamp = Instant.now().toEpochMilli();
   device.tags = Maps.newHashMap();
   device.tags.put("foo", "bar");
   device.fields = Maps.newHashMap();
   device.fields.put("temp", 14.8);


Create producer:

   Producer producer = client.newProducer(JSONSchema.of(Device.class))

.topic("persistent://public/default/foobar")
.producerName("test")
.create();

Send message:

   MessageId msgID = producer.newMessage()
.key("test")
.value(device)
.send();

Any suggestions how to do with Python ?

Thanks

GitHub link: https://github.com/apache/pulsar/discussions/22558


This is an automatically sent email for commits@pulsar.apache.org.
To unsubscribe, please send an email to: commits-unsubscr...@pulsar.apache.org

Re: [D] Python Producer Message to InfluxDBv2 sink connector with [pulsar]

2024-04-23 Thread via GitHub 


GitHub user smuehlmann edited a discussion: Python Producer Message to 
InfluxDBv2 sink connector with

Hi,

i have problems to send a message with a python producer which should be 
processed by an InfluxDBv2 sink connector.

With a java test code it is possible. 

Java class:

 public class Device  {
public String measurement;
public long timestamp;
public Map tags;
public Map fields;
   }

Set values:

Device device = new Device(); 
   device.measurement = "test5";
   device.timestamp = Instant.now().toEpochMilli();
   device.tags = Maps.newHashMap();
   device.tags.put("foo", "bar");
   device.fields = Maps.newHashMap();
   device.fields.put("temp", 14.8);


Create producer:

   Producer producer = client.newProducer(JSONSchema.of(Device.class))

.topic("persistent://public/default/foobar")
.producerName("test")
.create();

Send message:

   MessageId msgID = producer.newMessage()
.key("test")
.value(device)
.send();

Any suggestions how to do with Python ?

Thanks

GitHub link: https://github.com/apache/pulsar/discussions/22558


This is an automatically sent email for commits@pulsar.apache.org.
To unsubscribe, please send an email to: commits-unsubscr...@pulsar.apache.org