Re: [D] Pulsar 3.2.2 correct Message Format send to InfluxDBv2 sink connector with Python Producer [pulsar]

[via GitHub]

GitHub user smuehlmann edited a discussion: Pulsar 3.2.2 correct Message Format 
send to InfluxDBv2 sink connector with Python Producer

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<String, String> tags;
public Map<String, Object> 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);
`


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